We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 37a9a37 commit 69e3cb9Copy full SHA for 69e3cb9
src/manifold/stream.clj
@@ -196,10 +196,9 @@
196
`(.isSynchronous ~(with-meta x {:tag "manifold.stream.core.IEventStream"})))
197
198
(definline close!
199
- "Closes a sink, so that it can't emit any more messages.
+ "Closes a sink, so you can't `put!` any more messages onto it.
200
201
- Note that 'take's on associated sources will still work until
202
- the sink is exhausted."
+ Note that if it's also a source, `take!`s will still work until the source is drained."
203
204
[sink]
205
`(.close ~(with-meta sink {:tag "manifold.stream.core.IEventStream"})))
0 commit comments