org.purefn.river.flush — org.purefn/river 0.1.2

Experimental.

Higher order functions used to compose an auto-flushing processing function.

accumulate clj

(accumulate processor)

Accumulate records into state, and increments a count.

flush clj

(flush flush-fn)

Wrap the flush fn.

max-records clj

(max-records processor n)

Identifies a maximum record count flush condition.

timed clj

(timed processor ms)

Identifies buffer age as a condition for flushing.