calling into clojure-based streams code and back out into Akwire