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
Post a Comment