Using existing RxJava features we can reduce some code.
Also there are some style/genrics warnings.
Modifications
Custom class ObservableIO replaced by an existing RxJavaString library that provides stream reading as Observables.
Custom class PrintSubscriber replaced by Observable.doOnNext()
Removed the "unchecked assignment generic" warning for Subscriber
Removed some other warnings/style issues.
PS: @yschimke I am not sure whether you intentionally did not use these RxJava constructs or you were unaware. So, feel free to reject the changes 😄
Problem (not really)
Using existing
RxJava
features we can reduce some code. Also there are some style/genrics warnings.Modifications
ObservableIO
replaced by an existingRxJavaString
library that provides stream reading asObservable
s.PrintSubscriber
replaced byObservable.doOnNext()
Subscriber
PS: @yschimke I am not sure whether you intentionally did not use these RxJava constructs or you were unaware. So, feel free to reject the changes 😄