Added timeflies example with AsyncRx

Author: dbrattli

examples/timeflies/Program.fs

@@ -0,0 +1,83 @@
+// Learn more about F# at http://docs.microsoft.com/dotnet/fsharp
+module Program
+
+open System
+open FSharp.Control
+open Fable.Python
+open Fable.Python.TkInter
+open Fable.Python.Queue
+
+type Msg =
+    | Place of label: Label * x: int * y: int
+    //| Place of  x: int * y: int
+    | Empty
+
+let root = Tk()
+root.title("Fable Python Rocks on Tkinter!")
+let queue = Queue<Msg> ()
+
+let source, mouseMoves: IAsyncObserver<int*int>*IAsyncObservable<int*int> = AsyncRx.subject()
+
+let workerAsync (mb: MailboxProcessor<Event>) =
+    let rec messageLoop () =
+        async {
+            let! event = mb.Receive ()
+            do! source.OnNextAsync((event.x, event.y))
+
+            return! messageLoop ()
+        }
+    messageLoop ()
+
+let agent = MailboxProcessor<TkInter.Event>.Start(workerAsync)
+
+let frame = Frame(root, width=800, height=600, bg="white")
+frame.bind("<Motion>", agent.Post) |> ignore
+frame.pack()
+
+let stream =
+    Seq.toList "TIME FLIES LIKE AN ARROW"
+    |> Seq.mapi (fun i c -> i, Label(frame, text=(string c), fg="black", bg="white"))
+    |> AsyncRx.ofSeq
+    |> AsyncRx.flatMap (fun (i, label) ->
+        mouseMoves
+        |> AsyncRx.delay (100 * i)
+        |> AsyncRx.map (fun (x, y) -> label, x + i * 12 + 15, y))
+
+let sink (ev: Notification<Label*int*int>) =
+    async {
+        match ev with
+        | OnNext (label, x, y) -> queue.put(Place(label, x, y))
+        | OnError(err) -> printfn $"Stream Error: {err}"
+        | _ -> printfn "Stream Completed"
+        return ()
+    }
+
+let mainAsync =
+    async {
+        use! disposable = stream.SubscribeAsync(sink)
+        
+        let rec update () =
+            let size = queue.qsize()
+            for _ in 1..size do
+                let msg = queue.get(false)
+
+                match msg with
+                | Place (label, x, y) -> label.place(x, y)
+                | _ -> ()
+
+            match size with
+            | n when n > 0 -> root.after(1, update)
+            | _ -> root.after(10, update)
+
+        root.after(1, update)
+        root.mainloop()
+
+        return ()
+    }
+
+[<EntryPoint>]
+let main argv =
+    printfn "Started ..."
+    Async.Start mainAsync
+
+    0 // return an integer exit code

examples/timeflies/TimeFlies.fsproj

@@ -0,0 +1,21 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net5.0</TargetFramework>
+    <WarnOn>3390;$(WarnOn)</WarnOn>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <Compile Include="Program.fs" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Fable.Python" Version="0.5.0" />
+    <PackageReference Include="FSharp.Control.AsyncRx" Version="1.6.0" />
+  </ItemGroup>
+  <ItemGroup>
+    <ProjectReference Include="../GitHub/Fable/src/Fable.Core/Fable.Core.fsproj" />
+  </ItemGroup>
+
+</Project>

flask/Fable.Python.Flask.fsproj

@@ -6,7 +6,7 @@
     <Author>Dag Brattli</Author>
     <Copyright>Dag Brattli</Copyright>
     <PackageLicenseFile>LICENSE</PackageLicenseFile>
-    <Version>0.5.0</Version>
+    <Version>0.6.0</Version>
     <WarnOn>3390;$(WarnOn)</WarnOn>
   </PropertyGroup>
   <ItemGroup>

src/Fable.Python.fsproj

@@ -29,7 +29,7 @@ type Tk (screenName: string option) =
 
     member _.update() = nativeOnly
     member _.mainloop() = nativeOnly
-    member _.after(second: float, callback: unit -> unit) = nativeOnly
+    member _.after(msecs: int, callback: unit -> unit) = nativeOnly
 
 [<Import("Frame", "tkinter")>]
 type Frame(master: Misc) =