Liking cljdoc? Tell your friends :D
All platforms.
promisespromises.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
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
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close