Added AsObservable Event Extensions

Author: crazyjackel

Runtime/Scripts/EventExtensions.cs

@@ -0,0 +1,32 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using UniRx;
+using UniRx.Operators;
+using UnityEngine;
+using UnityEngine.UIElements;
+
+namespace RedMoon.ReactiveKit
+{
+    public static class EventExtensions
+    {
+        public static IObservable<TEventType> AsObservable<TEventType>(this VisualElement element) where TEventType : EventBase<TEventType>, new()
+        {
+            return new EventCallbackObservable<TEventType>(element);
+        }
+    }
+
+    internal class EventCallbackObservable<TEventType> : OperatorObservableBase<TEventType> where TEventType : EventBase<TEventType>, new()
+    {
+        readonly VisualElement element;
+        public EventCallbackObservable(VisualElement element) : base(true)
+        {
+            this.element = element;
+        }
+
+        protected override IDisposable SubscribeCore(IObserver<TEventType> observer, IDisposable cancel)
+        {
+            return element.BindCallback<TEventType>(x => observer.OnNext(x));
+        }
+    }
+}

Runtime/Scripts/EventExtensions.cs.meta

@@ -1,8 +1,10 @@
 using RedMoon.ReactiveKit;
+using System;
 using System.Collections;
 using System.Collections.Generic;
 using UniRx;
 using UnityEngine;
+using System.Linq;
 using UnityEngine.UIElements;
 
 namespace RedMoon.ReactiveKit.Samples
@@ -21,7 +23,17 @@ public override void OnActivation(MainViewModel viewModel, CompositeDisposable d
             //Bind such that whenever OnButtonClick can Execute, you can click button.
             //Bind such that whenever Button is clicked, it executes OnButtonClick.
             button.BindClick(viewModel.OnButtonClick).AddTo(disposable);
-            
+
+            //Turn Event into Observable
+            //Buffer based on Throttle Window
+            //Check that there is more than 2 clicks
+            //Double Click Detected
+            var clickStream = button.AsObservable<ClickEvent>();
+            clickStream.Buffer(clickStream.Throttle(TimeSpan.FromMilliseconds(250))).Where(xs => xs.Count >= 2).Subscribe(x =>
+            {
+                viewModel.OnDoubleClick.Execute(x.Last());
+            });
+
             //Bind such that whenever DebugText changes, it updates label value.
             label.BindToValueChanged(viewModel.DebugText).AddTo(disposable);
 

Samples/SamplesBasicUI/Scripts/MainView.cs

@@ -14,13 +14,18 @@ public class MainViewModel : ViewModel<MainViewModel>
         public ReactiveProperty<string> ReactiveText { get; protected set; } = new ReactiveProperty<string>("");
 
         public ReactiveCommand<ClickEvent> OnButtonClick;
+        public ReactiveCommand<ClickEvent> OnDoubleClick;
         public ReactiveCommand<ChangeEvent<string>> OnTextFieldChange;
 
         public override void OnInitialization()
         {
             OnButtonClick = new ReactiveCommand<ClickEvent>();
             OnButtonClick.Subscribe((c) => UpdateDebugText(c, "Button Clicked"));
 
+            OnDoubleClick = new ReactiveCommand<ClickEvent>();
+            OnDoubleClick.Subscribe((c) => UpdateDebugText(c, "Double Clicked"));
+
+
             OnTextFieldChange = new ReactiveCommand<ChangeEvent<string>>();
             OnTextFieldChange.Subscribe((c) => UpdateDebugText(c, "Field Changed:"));
         }