rx java - RxJava - add new Observable at top of the chain -


is possible add new observable on top of observable chain merged? or
whenever create new observable, have build new observable?

assume have merged observable like

val trackable1: publishsubject[jsonobject] = publishsubject.create() val flushable: publishsubject[jsonobject] = publishsubject.create() val merged = flushable               .mergedwith(trackable)               .map(json -> {                 if (storage.size > 50)                 // send http request               });  val trackable2: publishsubject[jsonobject] = publishsubject.create()  // add trackable2 event source trackable1 // without rebuilding `merged` observable. 

thanks.


Comments

Popular posts from this blog

angularjs - ADAL JS Angular- WebAPI add a new role claim to the token -

php - CakePHP HttpSockets send array of paramms -

node.js - Using Node without global install -