Consume Twitter Streams using Spray-Client and map them to a RxJava observable