Proof of concept that converts Spray's chunks to Observable events. Right now it reads the chunks from Twitter's stream.
Special thanks to Jan Machacek's blog and code
TODO
-
Subscribing an Observer should really use an RxJava scheduler. Right now the log is showing that it's using the threads of the Akka scheduler.
-
Check out if rxjava-akka may be useful.