clojurewerkz.meltdown.streams — clojurewerkz/meltdown 1.1.0

accept clj

(accept deferred value)

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.

consume clj

(consume stream f)

Defines a consumer for stream.

create clj

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

Creates a stream processing channel

custom-stream clj

(custom-stream f deferred-or-stream)

dispatcher-types clj

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.

flush clj

(flush deferred-or-stream)

fmap* clj

(fmap* f deferred-or-stream)

fold* clj

(fold* f deferred-or-stream)

map* clj

(map* f deferred-or-stream)

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

mappend* clj

(mappend* monoid deferred-or-stream)

(mappend* monoid condition deferred-or-stream)

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.

tap clj

(tap stream)