cljs-thread.injest

Liking cljdoc? Tell your friends :D

Mostly cljs.
Exceptions indicated.

*chunk*
*par*
=>>^clj/s
fan
mk-injest-ids
pre-transducify-thread^clj
start-injests
tfan^clj/s

chunk^cljs

source

par^cljs

source

=>>^clj/smacro

(=>> x & thread)

Just like x>> but first composes stateless transducers into a function that r/folds in parallel the values flowing through the thread. Remaining stateful transducers are composed just like x>>.

Just like x>> but first composes stateless transducers into a function that 
`r/fold`s in parallel the values flowing through the thread. Remaining
stateful transducers are composed just like x>>.

source raw docstring

fan^cljs

(fan conveyer xf args & {:keys [par chunk]})

source

mk-injest-ids^cljs

(mk-injest-ids & [n])

source

pre-transducify-thread^clj

(pre-transducify-thread conveyer
                        names
                        env
                        minimum-group-size
                        t-fn
                        t-pred
                        thread)

source