You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Flowable.observeOn and Observable.observeOn try to do as much event delivery as they can.
Add a section explaining this property to all these multi-valued observeOn overloads:
"This operator keeps emitting as many signals as it can on the given Scheduler's Worker thread, which may result in a longer than expected occupation of this thread. In other terms, it does not allow per-signal fairness in case the worker runs on a shared underlying thread. If such fairness and signal/work interleaving is preferred, use the delay operator with zero time instead."
Also link to the @see #delay(long,TimeUnit,Scheduler).
The text was updated successfully, but these errors were encountered:
@akarnokd could you take a look at this? dariuszseweryn/RxAndroidBle#628
You can just test my last example, your suggestion to use delay() did not help me solve the problem.
Flowable.observeOn
andObservable.observeOn
try to do as much event delivery as they can.Add a section explaining this property to all these multi-valued
observeOn
overloads:"This operator keeps emitting as many signals as it can on the given Scheduler's Worker thread, which may result in a longer than expected occupation of this thread. In other terms, it does not allow per-signal fairness in case the worker runs on a shared underlying thread. If such fairness and signal/work interleaving is preferred, use the
delay
operator with zero time instead."Also link to the
@see #delay(long,TimeUnit,Scheduler)
.The text was updated successfully, but these errors were encountered: