This page is not created by, affiliated with, or supported by Slack Technologies, Inc.
2018-04-27
Channels
- # architecture (6)
- # beginners (36)
- # boot (4)
- # cider (74)
- # cljsrn (5)
- # clojure (87)
- # clojure-denver (2)
- # clojure-finland (2)
- # clojure-gamedev (5)
- # clojure-italy (10)
- # clojure-nl (1)
- # clojure-uk (45)
- # clojurescript (33)
- # code-reviews (5)
- # core-async (12)
- # cursive (17)
- # datascript (2)
- # datomic (71)
- # duct (4)
- # emacs (19)
- # figwheel (1)
- # fulcro (4)
- # garden (1)
- # hoplon (18)
- # jobs (5)
- # leiningen (2)
- # off-topic (73)
- # onyx (14)
- # overtone (2)
- # portkey (32)
- # re-frame (62)
- # reagent (46)
- # shadow-cljs (76)
- # spacemacs (2)
- # sql (14)
- # tools-deps (5)
- # yada (3)
hi, I'm trying to query a large resultset onto an async channel so my :row-fn
looks something like #(>!! db-chan)
, what would be a good :result-set-fn
? I am using j/query
and wondering if i have to get lower level to (patiently) stream out a lot of results.
and i'm afraid anything else might close the cursor if the chan is blocking (temporarily)
@joefromct Take a look at reducible-query
. I think that might be a better option.
@seancorfield sure thing, thank you
@joefromct FYI, you do not need with-db-connection
there -- you can pass db-spec
directly to query
.
Did you look at reducible-query
? It's intended for lazily read large streams of data from the DB.
I'm still playing with it, i think i'm going to toy with my partitioning in the channels and the insert-multi!
maybe async is overkill, i just like t he idea of being able to inject other functions into the xf in that pipeline i guess