Flexible, Safe and Simple Multi-Consumer/Producer Clojure Pipelines