android - RXJava - onBackpressureBuffer + multiple observers not working -


i have observable , subscribe it. need not miss emitted result, use onbackpressurebuffer following:

observable<data> observable = observable.onbackpressurebuffer(); if (buildconfig.debug) {     observable          .subscribeon(handlerscheduler.from(datamanager.getbackgroundhandler()))         .observeon(handlerscheduler.from(datamanager.getbackgroundhandler()))         .subscribe(new measuringsubscriber(...)); } // here real observer need in app observable         .subscribeon(handlerscheduler.from(datamanager.getbackgroundhandler()))         .observeon(androidschedulers.mainthread())         .subscribe(new observer<data>()         {             @override             public void oncompleted() {              }              @override             public void onerror(throwable e) {              }              @override             public void onnext(data data) {              }         }); 

the measuringsubscriber custom subscriber logs how long task needs, that's all.

problem

if add measuringsubscriber, subscribers not work anymore , never emit result. why? , how can make working?

edit - new problem

currently it's working, measuringsubscriber somehow blocking, meaning, first items emitted 1 one measuringsubscriber , afterwards items emitted 1 one main subscriber... ideas cause that?

i have solution - can extend main observalbe measuringobservable - rather know why happens , how avoid this...

i tried using publish + connect, still emit items first subscriber before emitting them second one...


Comments

Popular posts from this blog

get url and add instance to a model with prefilled foreign key :django admin -

css - Make div keyboard-scrollable in jQuery Mobile? -

android - Keyboard hides my half of edit-text and button below it even in scroll view -