Liking cljdoc? Tell your friends :D
All platforms.
prpr3.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 | :prpr3.stream/end>
take chunks or plain values from a stream paying attention to errors - returns Promise<chunk | value | error | :prpr3.stream/end>
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)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)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)IStreamFactoryclj/s≠protocol
-streamclj/s≠
clj
(-stream _)(-stream _ buffer)(-stream _ buffer xform)(-stream _ buffer xform executor)cljs
(-stream _)(-stream _ buffer)(-stream _ buffer xform)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 | :prpr3.stream/end>
take single values from a stream paying attention to chunks and errors - returns Promise<value | error | :prpr3.stream/end>
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close