Liking cljdoc? Tell your friends :D

prpr3.stream.zip-impl

consume from multiple streams in a chunk and error sensitive way

consume from multiple streams in a chunk and
error sensitive way
raw docstring

chunk-consumerclj/s

(chunk-consumer s)
source

chunk-zipclj/s

(chunk-zip & srcs)

zip values from input streams to vectors on the output stream in a chunk and error sensitive way

(chunk-zip Stream<a> Stream<b> Stream<c> ...) -> Stream<[a b c ...]>

if the inputs are all chunked then the output will also be chunked. the size of the output chunks will be determined by the smallest chunk size of the inputs

one of the more complex consumption patterns - not dissimilar to a join in that it consumes multiple streams, consumes partial chunks and pushes unconsumed values 'back' onto streams

zip values from input streams to vectors on the output stream in
a chunk and error sensitive way

(chunk-zip Stream<a> Stream<b> Stream<c> ...) -> Stream<[a b c ...]>

if the inputs are all chunked then the output will also be chunked.
the size of the output chunks will be determined by the smallest
chunk size of the inputs

one of the more complex consumption patterns - not dissimilar to
a join in that it consumes multiple streams, consumes partial chunks
and pushes unconsumed values 'back' onto streams
sourceraw docstring

value-consumerclj/s

(value-consumer s)
source

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

× close