[Proposal] Convert StreamingMarketDataService functions from Observable to CompletableObservable

[makarid]

Hello, because i think we need all the streaming public data to be a hot observable and never complete, is it ok to convert the functions from Observable<X> to CompletableObservable<X> ? Thanks

[mrmx]

The streaming api is well designed using rx Observables, you maybe talking about backpressure and that's available with a simple call in observable.toFlowable()

Have a look at this articles:

• rxjava-2-flowable
• rxjava-backpressure

[makarid]

I am using Flowable in my implementation and i think that many here are doing some kind of conversion from Observable to something else for production, that is why i am starting this thread. Maybe it is only me, but maybe there are others also. Thanks