Liking cljdoc? Tell your friends :D

promisespromises.stream.protocols


IChunkConsumerclj/sprotocol

-peek-chunkclj/s

(-peek-chunk _)

peek a single chunk or value

peek a single chunk or value

-pushback-chunk!clj/s

(-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!clj/s

(-take-chunk! _)

take chunks or plain values from a stream paying attention to errors

  • returns Promise<chunk | value | error | :promisespromises.stream/end>
take chunks or plain values from a stream paying attention to errors
- returns Promise<chunk | value | error | :promisespromises.stream/end>
source

IMaybeStreamclj/sprotocol

-stream?clj/s

(-stream? this)
source

IPlatformErrorWrapperclj/sprotocol

-unwrap-platform-errorclj/s

(-unwrap-platform-error _)
source

IStreamclj/sprotocol

-bufferclj/s

(-buffer _ n)

-close!clj/s

(-close! this)

-closed?clj/s

(-closed? s)

-connect-viaclj/s

(-connect-via source f sink)
(-connect-via source f sink opts)

-put!clj/s

(-put! sink val)
(-put! sink val timeout timeout-val)

-take!clj/s

(-take! source)
(-take! source default-val)
(-take! source default-val timeout timeout-val)

-wrap-valueclj/s

(-wrap-value _ v)
source

IStreamChunkclj/sprotocol

-chunk-flattenclj/s

(-chunk-flatten this)

flatten any nested promises returning Promise<value>

flatten any nested promises returning Promise<value>

-chunk-valuesclj/s

(-chunk-values this)
source

IStreamChunkBuilderclj/sprotocol

-add-all-to-chunkclj/s

(-add-all-to-chunk _ vals)

-add-to-chunkclj/s

(-add-to-chunk _ val)

-building-chunk?clj/s

(-building-chunk? _)

-chunk-stateclj/s

(-chunk-state _)

-discard-chunkclj/s

(-discard-chunk _)

-finish-chunkclj/s

(-finish-chunk _)
(-finish-chunk _ val)

-start-chunkclj/s

(-start-chunk _)
(-start-chunk _ val)
source

IStreamErrorclj/sprotocol

-unwrap-errorclj/s

(-unwrap-error _)
source

IStreamFactoryclj/s≠protocol

-streamclj/s≠

clj
(-stream _)
(-stream _ buffer)
(-stream _ buffer xform)
(-stream _ buffer xform executor)
cljs
(-stream _)
(-stream _ buffer)
(-stream _ buffer xform)
source

IStreamValueclj/sprotocol

-unwrap-valueclj/s

(-unwrap-value _)
source

IValueConsumerclj/sprotocol

-peek-valueclj/s

(-peek-value _)

peek a single value

peek a single value

-take-value!clj/s

(-take-value! _)

take single values from a stream paying attention to chunks and errors

  • returns Promise<value | error | :promisespromises.stream/end>
take single values from a stream paying attention to chunks and errors
- returns Promise<value | error | :promisespromises.stream/end>
source

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

× close