- act
- async-map
- cache
- cat
- catch
- collect
- combine
- count
- defer
- defer-source
- defer-through
- drain
- empty
- error
- filter
- flatmap
- flatmerge
- flatten
- high-watermark
- infinite
- many
- map
- notify
- on-end
- once
- pair
- promise-source
- promise-through
- pushable
- read-stream-to-source
- stream
- take
- tap
- tee
- through
- timeout-source
- timeout-through
- values
- write-stream-to-source
- zip
tenfold.pull-stream
actcljs
(act & sources)Yields from the given sources (in sequence) but also discard their values. This is useful for sources with side effects.
Yields from the given sources (in sequence) but also discard their values. This is useful for sources with side effects.
async-mapcljs
cachecljs
catcljs
(cat & args)catchcljs
collectcljs
combinecljs
(combine & sources)Combine multiple sources into one source, emitting values as they come.
When one stream errors, all streams are aborted and the error is propagated downstream.
When all streams end, the combined stream ends.
This function does not respect back pressure. That is, it drains values from the sources as soon as they come, regardless of whether values are being read from the combined stream.
Combine multiple sources into one source, emitting values as they come. When one stream errors, all streams are aborted and the error is propagated downstream. When all streams end, the combined stream ends. This function does not respect back pressure. That is, it drains values from the sources as soon as they come, regardless of whether values are being read from the combined stream.
countcljs
defercljs
(defer)Returns [resolve, source]. In the following example, the second stream
starts only after the first ends.
(let [[resolve source] (p/defer)] (p/stream (p/on-end resolve)) (p/stream (source (p/values [1 2 3]))))
Returns `[resolve, source]`. In the following example, the second stream
starts only after the first ends.
(let [[resolve source] (p/defer)]
(p/stream
(p/on-end resolve))
(p/stream
(source (p/values [1 2 3]))))defer-sourcecljs
defer-throughcljs
draincljs
emptycljs
errorcljs
filtercljs
flatmapcljs
(flatmap f)flatmergecljs
flattencljs
high-watermarkcljs
infinitecljs
manycljs
(many & args)mapcljs
notifycljs
(notify)on-endcljs
oncecljs
paircljs
(pair)promise-sourcecljs
(promise-source f)Takes a function that returns a promise.
Takes a function that returns a promise.
promise-throughcljs
(promise-through f)Takes a function that takes a value and returns a promise.
Takes a function that takes a value and returns a promise.
pushablecljs
(pushable)(pushable done)Returns a [push end source] tuple where:
pushpushes an event into the source.endends the source.sourceis the source.
Returns a `[push end source]` tuple where: - `push` pushes an event into the source. - `end` ends the source. - `source` is the source.
read-stream-to-sourcecljs
streamcljs
takecljs
tapcljs
teecljs
throughcljs
timeout-sourcecljs
(timeout-source val n)Returns a source that behaves like once except that it only yields the
value after n milliseconds.
Returns a source that behaves like `once` except that it only yields the value after `n` milliseconds.
timeout-throughcljs
(timeout-through n)Returns a through that blocks initially, but functions as a noop after n
milliseconds.
Returns a through that blocks initially, but functions as a noop after `n` milliseconds.
valuescljs
(values xs)write-stream-to-sourcecljs
zipcljs
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close