Fix line endings.
Add EOS callback and basic ZMQ implementation of streaming.