Hi All, im struggling with something that is probably simple but im not seeing an obvious answer in the docs: I'd like the streaming equivalent of (take x (drop y coll)). I've been playing with async/transduce, async/pipeline, and async/take, but they alone do not seem to be quite what I needed. For instance, transduce of course buffers, pipeline is stateless, and I dont see the async/drop cousin to drop as I do for async/take -> take
what am I missing?
For instance, this logically does what I want:
(async/transduce
(comp (take limit) (drop offset))
conj
[])
aside from the fact that the results are deferred until its completechannels accept a transducer, is it possible to supply this transducer to your channel?