aboutsummaryrefslogtreecommitdiff
path: root/stdlib/source/library/lux/control/concurrency/frp.lux
diff options
context:
space:
mode:
authorEduardo Julian2021-08-16 01:12:01 -0400
committerEduardo Julian2021-08-16 01:12:01 -0400
commit3289b9dcf9d5d1c1e5c380e3185065c8fd32535f (patch)
treefc2f67581dd7b1d72c20217a95e031187a375bc5 /stdlib/source/library/lux/control/concurrency/frp.lux
parent6fd22846f21b8b70b7867e989109d14a366c0a3e (diff)
Made extension-definition macros specify their bindings the same way as syntax:.
Diffstat (limited to 'stdlib/source/library/lux/control/concurrency/frp.lux')
-rw-r--r--stdlib/source/library/lux/control/concurrency/frp.lux9
1 files changed, 0 insertions, 9 deletions
diff --git a/stdlib/source/library/lux/control/concurrency/frp.lux b/stdlib/source/library/lux/control/concurrency/frp.lux
index 676aa0b8a..e14fb6505 100644
--- a/stdlib/source/library/lux/control/concurrency/frp.lux
+++ b/stdlib/source/library/lux/control/concurrency/frp.lux
@@ -18,13 +18,11 @@
["." async (#+ Async) ("#\." functor)]])
(type: .public (Channel a)
- {#.doc "An asynchronous channel to distribute values."}
(Async (Maybe [a (Channel a)])))
(exception: .public channel_is_already_closed)
(interface: .public (Sink a)
- {#.doc (example "The tail-end of a channel, which can be written-to to fee the channel.")}
(: (IO (Try Any))
close)
(: (-> a (IO (Try Any)))
@@ -80,7 +78,6 @@
(recur []))))))))))
(def: .public (channel _)
- {#.doc (example "Creates a brand-new channel and hands it over, along with the sink to write to it.")}
(All [a] (-> Any [(Channel a) (Sink a)]))
(let [[async resolve] (async.async [])]
[async (..sink resolve)]))
@@ -150,7 +147,6 @@
output))))
(type: .public (Subscriber a)
- {#.doc (example "A function that can receive every value fed into a channel.")}
(-> a (IO (Maybe Any))))
(def: .public (subscribe! subscriber channel)
@@ -174,8 +170,6 @@
[])))
(def: .public (only pass? channel)
- {#.doc (example "Produces a new channel based on the old one, only with values"
- "that pass the test.")}
(All [a] (-> (-> a Bit) (Channel a) (Channel a)))
(do async.monad
[item channel]
@@ -190,14 +184,12 @@
(in #.None))))
(def: .public (of_async async)
- {#.doc (example "A one-element channel containing the output from an async.")}
(All [a] (-> (Async a) (Channel a)))
(async\map (function (_ value)
(#.Some [value ..empty]))
async))
(def: .public (fold f init channel)
- {#.doc "Asynchronous fold over channels."}
(All [a b]
(-> (-> b a (Async a)) a (Channel b)
(Async a)))
@@ -291,7 +283,6 @@
(in #.End))))
(def: .public (sequential milli_seconds values)
- {#.doc (example "Transforms the given list into a channel with the same elements.")}
(All [a] (-> Nat (List a) (Channel a)))
(case values
#.End