prpr3.stream.test — com.github.yapsterapp/promisespromises 3.0-alpha1

consume clj/s

(consume s)

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

safe-consume clj/s

(safe-consume s)

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

safe-low-consume clj/s

(safe-low-consume s)

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

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

safe-take! clj/s

(safe-take! s & args)

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

stream-of clj/s

(stream-of vs)

returns a stream of the individual values (not chunked)