This page is not created by, affiliated with, or supported by Slack Technologies, Inc.
2020-11-01
Channels
- # babashka (1)
- # beginners (28)
- # calva (28)
- # cider (8)
- # clj-kondo (1)
- # clojars (4)
- # clojure (20)
- # clojure-australia (1)
- # clojure-europe (13)
- # clojure-uk (2)
- # clojurescript (2)
- # conjure (4)
- # core-async (4)
- # cryogen (3)
- # datomic (17)
- # fulcro (3)
- # helix (45)
- # malli (9)
- # off-topic (6)
- # pathom (3)
- # re-frame (13)
- # reitit (17)
- # sci (1)
- # shadow-cljs (9)
- # sql (6)
- # tools-deps (11)
- # vim (17)
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
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?