Devise an appropriate means for reading stream data from a long-lived HTTP connection

[oubiwann]

Subtask of feature #56.

Related:

• Add RecordIO parsing #18 - RecordIO parsing
• Create a namespace and functions for parsing streamed data #52 - Create a namespace and functions for parsing streamed data

Resources for processing streaming byte data in Clojure (e.g., with clj-http):

• https://docs.oracle.com/javase/7/docs/api/java/io/InputStream.html
• https://github.com/dakrone/clj-http/blob/3c1894ff295acd569dcd90aaee5e8ee5a4beadfe/examples/progress_download.clj
• https://gist.github.com/jafingerhut/1c61ec6b99a7656895e0
• https://gist.github.com/dakrone/5577106
• http://stackoverflow.com/questions/30125909/processing-a-stream-of-messages-from-a-http-server-in-clojure
• http://stackoverflow.com/questions/17376269/clojure-creating-a-lazy-sequence-of-byte-chunks-from-an-input-stream

[oubiwann]

Okay, got something in place for this (locally). Will start pushing changes to code ...

[oubiwann]

We're doing this through a combination of the new IRecordIOStream protocol and core.async, using async/put!, async/go-loop, and async/reduce.

It's not yet clear where the async calls will ultimately live, but for now the object has been attained: devising complete.