java - Accumulate Observables from different Streams for polling -


i'm trying accumulate observables server calls, flatmapping them , make server call.

private observable poll(observable<taskstatus> taskobservable) {      observable.add(taskobservable) //pseudocode     .buffer(3 sec)      .flatmap(...)     ... } 

how can observable accumulation ("add") achieved?

you're looking merge() operator.

for more information on combining observables, see this: https://github.com/netflix/rxjava/wiki/combining-observables


Comments

Popular posts from this blog

Android Java.Lang.RuntimeException : Unable to start activity Component Info -

c# - Sort XmlNodeList with a specific Node value -

actionscript 3 - Equivalent to moveReceived in ElectroServer 5 -