teaforthecat/gist:d250d355225133c57f1da2c3eb191616

Created February 11, 2019 23:07

Star (0) You must be signed in to star a gist
Fork (0) You must be signed in to fork a gist

Learn more about clone URLs
Clone this repository at <script src="https://gist.github.com/teaforthecat/d250d355225133c57f1da2c3eb191616.js"></script>
Save teaforthecat/d250d355225133c57f1da2c3eb191616 to your computer and use it in GitHub Desktop.

Download ZIP

lazy stream of kafka messages in clojure

Raw

gistfile1.txt

	(defn message-stream
	([c]
	(message-stream c ()))
	([c a]
	(lazy-seq
	(cons a
	(message-stream c (seq (poll! c)))))))

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment