diff options
Diffstat (limited to 'stdlib/source/library/lux/control/concurrency/frp.lux')
| -rw-r--r-- | stdlib/source/library/lux/control/concurrency/frp.lux | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/stdlib/source/library/lux/control/concurrency/frp.lux b/stdlib/source/library/lux/control/concurrency/frp.lux index 252b8f0ce..15f599f8f 100644 --- a/stdlib/source/library/lux/control/concurrency/frp.lux +++ b/stdlib/source/library/lux/control/concurrency/frp.lux @@ -149,7 +149,7 @@ (case ?ma {.#Some [a ma']} (exec - (io.run! (# sink feed (variance.read a))) + (io.run! (at sink feed (variance.read a))) (again (variance.write ma'))) {.#None} @@ -157,7 +157,7 @@ (again mma')) {.#None} - (in (is Any (io.run! (# sink close)))))))) + (in (is Any (io.run! (at sink close)))))))) output)))) (type: .public (Subscriber a) @@ -244,7 +244,7 @@ (io.run! (loop (again [_ []]) (do io.monad [value action - _ (# sink feed value)] + _ (at sink feed value)] (async.upon! again (async.delay milli_seconds))))) [output sink]))) @@ -269,7 +269,7 @@ [item channel] (case item {.#Some [head tail]} - (if (# equivalence = previous (variance.read head)) + (if (at equivalence = previous (variance.read head)) (distinct' equivalence previous tail) (in {.#Some [head (distinct' equivalence (variance.read head) tail)]})) @@ -293,8 +293,8 @@ [item channel] (case item {.#Some [head tail]} - (# ! each (|>> {.#Item (variance.read head)}) - (list tail)) + (at ! each (|>> {.#Item (variance.read head)}) + (list tail)) {.#None} (in {.#End})))) |