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

rest - Spring boot: Request method 'PUT' not supported -

php - Magento - Deleted Base url key -

symfony - imagine_filter() not generating the correct url in LiipImagineBundle -