Reactive Hooks

reactivehooks.cs

using System;
using System.Reactive.Linq;
using System.Reactive.Subjects;
using System.Threading.Tasks;
using Starcounter;

namespace StarcounterRx
{
    class Program
    {
        static void Main()
        {
            Application.Current.Use(new HtmlFromJsonProvider());
            Application.Current.Use(new PartialToStandaloneHtmlProvider());

            CreateEntitiesInBackground();


            Handle.GET("/push", () =>
            {
                Session.Current = new Session(SessionOptions.PatchVersioning);

                var session = Session.Current.SessionId;
                var page = new MainPage();

                ObservableEntity<DateTimeEntity>
                    .Inserted
                    .Where(i => i.Time % 2 == 0)
                    .Subscribe(e =>
                    {
                        Session.ScheduleTask(session, (s, id) =>
                        {
                            page.Time = e.Time.ToString();
                            s.CalculatePatchAndPushOnWebSocket();
                        });
                    });

                return page;
            });
        }

        private static void CreateEntitiesInBackground()
        {
            Task.Run(async () =>
            {
                while (true)
                {
                    await Scheduling.RunTask(() =>
                    {
                        Db.Transact(() =>
                        {
                            new DateTimeEntity()
                            {
                                Time = DateTime.Now.Ticks,
                            };
                        });
                    });
                    await Task.Delay(1000);
                }
            });
        }
    }


    public static class ObservableEntity<T>
    {

        public static Subject<T> Inserted = new Subject<T>();
        public static Subject<T> Updated = new Subject<T>();

        static ObservableEntity()
        {
            Hook<T>.CommitInsert += (sender, t) => { Inserted.OnNext(t); };
            Hook<T>.CommitUpdate += (sender, t) => { Updated.OnNext(t); };
        }
    }

    [Database]
    public class DateTimeEntity
    {
        public long Time { get; set; }
    }
}