diff options
Diffstat (limited to '')
| -rw-r--r-- | stdlib/source/library/lux/control/concurrency/frp.lux | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/stdlib/source/library/lux/control/concurrency/frp.lux b/stdlib/source/library/lux/control/concurrency/frp.lux index b5005661a..e5fcac64d 100644 --- a/stdlib/source/library/lux/control/concurrency/frp.lux +++ b/stdlib/source/library/lux/control/concurrency/frp.lux @@ -14,6 +14,7 @@ [meta ["[0]" type (.only sharing)]]]] [// + [thread (.only Delay)] ["[0]" atom (.only Atom)] ["[0]" async (.only Async Async') (.use "[1]#[0]" monad)]]) @@ -237,7 +238,7 @@ (def .public (poll milli_seconds action) (All (_ a) - (-> Nat (IO a) [(Channel a) (Sink a)])) + (-> Delay (IO a) [(Channel a) (Sink a)])) (let [[output sink] (channel [])] (exec (io.run! (loop (again [_ []]) @@ -248,7 +249,7 @@ [output sink]))) (def .public (periodic milli_seconds) - (-> Nat [(Channel Any) (Sink Any)]) + (-> Delay [(Channel Any) (Sink Any)]) (..poll milli_seconds (io []))) (def .public (iterations f init) @@ -299,7 +300,7 @@ (in {.#End})))) (def .public (sequential milli_seconds values) - (All (_ a) (-> Nat (List a) (Channel a))) + (All (_ a) (-> Delay (List a) (Channel a))) (when values {.#End} ..empty |