waterfall

Manifold utilities.

• Creation of streams with sliding buffer

Usage

Dependency: [jetmind/waterfall "0.1.0"]

(require '[jetmind.waterfall :as w])

(def s (w/sliding-stream 10))

Works pretty much as you would expect. put!'s always succeed (replacing oldest element if buffer is full).