promisespromises.stream.test

Liking cljdoc? Tell your friends :D

All platforms.

(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>]

(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

(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

(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>]>

(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>]>

(stream-of vs)

returns a stream of the individual values (not chunked)

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

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