(-peek-chunk _)peek a single chunk or value
peek a single chunk or value
(-pushback-chunk! _ chunk-or-val)push a chunk or values back onto the logical stream (into the buffer)
push a chunk or values back onto the logical stream (into the buffer)
(-take-chunk! _)take chunks or plain values from a stream paying attention to errors
take chunks or plain values from a stream paying attention to errors - returns Promise<chunk | value | error | :promisespromises.stream/end>
(-buffer _ n)(-close! this)(-closed? s)(-connect-via source f sink)(-connect-via source f sink opts)(-put! sink val)(-put! sink val timeout timeout-val)(-take! source)(-take! source default-val)(-take! source default-val timeout timeout-val)(-wrap-value _ v)(-chunk-flatten this)flatten any nested promises returning Promise<value>
flatten any nested promises returning Promise<value>
(-chunk-values this)(-add-all-to-chunk _ vals)(-add-to-chunk _ val)(-building-chunk? _)(-chunk-state _)(-discard-chunk _)(-finish-chunk _)(-finish-chunk _ val)(-start-chunk _)(-start-chunk _ val)(-stream _)(-stream _ buffer)(-stream _ buffer xform)(-stream _ buffer xform executor)(-stream _)(-stream _ buffer)(-stream _ buffer xform)(-peek-value _)peek a single value
peek a single value
(-take-value! _)take single values from a stream paying attention to chunks and errors
take single values from a stream paying attention to chunks and errors - returns Promise<value | error | :promisespromises.stream/end>
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |