Fork me on GitHub

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:

  (comp (take limit) (drop offset))
aside from the fact that the results are deferred until its complete


channels accept a transducer, is it possible to supply this transducer to your channel?