Liking cljdoc? Tell your friends :D

clojurewerkz.meltdown.streams


acceptclj

(accept deferred value)
source

batch*clj

(batch* i deferred-or-stream)

Defines a batch function that will accumulate values until it's reaches count of i, and streams the resulting array of values further down.

Defines a batch function that will accumulate values until it's reaches count of `i`, and
streams the resulting array of values further down.
sourceraw docstring

consumeclj

(consume stream f)

Defines a consumer for stream.

Defines a consumer for stream.
sourceraw docstring

createclj

(create & {:keys [dispatcher-type dispatcher values batch-size env]})

Creates a stream processing channel

Creates a stream processing channel
sourceraw docstring

custom-streamclj

(custom-stream f deferred-or-stream)
source

dispatcher-typesclj

source

filter*clj

(filter* f deferred-or-stream)

Defines a filter function, that will apply predicate f to all events going through it and will stream only those for which predicate returned truthy value.

Defines a filter function, that will apply predicate `f` to all events going through it
and will stream only those for which predicate returned truthy value.
sourceraw docstring

flushclj

(flush deferred-or-stream)
source

fmap*clj

(fmap* f deferred-or-stream)
source

fold*clj

(fold* f deferred-or-stream)
source

map*clj

(map* f deferred-or-stream)

Defines a map function, that will apply f to all events going through it.

Defines a map function, that will apply `f` to all events going through it.
sourceraw docstring

mappend*clj

(mappend* monoid deferred-or-stream)
(mappend* monoid condition deferred-or-stream)
source

reduce*clj

(reduce* f deferred-or-stream)
(reduce* f default-value deferred-or-stream)

Defines an aggregator funciton that will apply previous aggregator value and new incoming event to function f, receives default-value with which aggregator is initialized.

Defines an aggregator funciton that will apply previous aggregator value and new incoming event
to function `f`, receives `default-value` with which aggregator is initialized.
sourceraw docstring

tapclj

(tap stream)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close