Liking cljdoc? Tell your friends :D

prpr3.stream.test


consumeclj/s

(consume s)

consume a stream to a vector. an error will be added to the end of the vector as [::error <error>]

consume a stream to a vector. an error
will be added to the end of the vector
as [::error <error>]
sourceraw docstring

safe-consumeclj/s

(safe-consume s)

keep safe-take! ing until ::closed, returning a vector of safe-take!s

keep safe-take! ing until ::closed, returning
a vector of safe-take!s
sourceraw docstring

safe-low-consumeclj/s

(safe-low-consume s)

keep safe-low-take! ing until ::closed, returning a vector of safe-low-take!s

keep safe-low-take! ing until ::closed, returning
a vector of safe-low-take!s
sourceraw docstring

safe-low-take!clj/s

(safe-low-take! s & args)

take! directly from a stream impl without any unwrapping Promise<[::ok <val>]> | Promise<[::error <err>]>

take! directly from a stream impl without any unwrapping
Promise<[::ok <val>]> | Promise<[::error <err>]>
sourceraw docstring

safe-take!clj/s

(safe-take! s & args)

transport/take! (with unwrapping) from a stream returning Promise<[::ok <val>]> | Promise<[::error <err>]>

transport/take! (with unwrapping) from a stream returning
Promise<[::ok <val>]> | Promise<[::error <err>]>
sourceraw docstring

stream-ofclj/s

(stream-of vs)

returns a stream of the individual values (not chunked)

returns a stream of the individual values
(*not* chunked)
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close