T
- the transmitted value typepublic final class OperatorObserveOn<T> extends Object implements Observable.Operator<T,T>
Scheduler
asynchronously via an unbounded buffer.
Constructor and Description |
---|
OperatorObserveOn(Scheduler scheduler,
boolean delayError) |
OperatorObserveOn(Scheduler scheduler,
boolean delayError,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
Subscriber<? super T> |
call(Subscriber<? super T> child) |
static <T> Observable.Operator<T,T> |
rebatch(int n) |
public OperatorObserveOn(Scheduler scheduler, boolean delayError)
scheduler
- the scheduler to usedelayError
- delay errors until all normal events are emitted in the other thread?public OperatorObserveOn(Scheduler scheduler, boolean delayError, int bufferSize)
scheduler
- the scheduler to usedelayError
- delay errors until all normal events are emitted in the other thread?bufferSize
- for the buffer feeding the Scheduler workers, defaults to RxRingBuffer.MAX
if <= 0public Subscriber<? super T> call(Subscriber<? super T> child)
call
in interface Func1<Subscriber<? super T>,Subscriber<? super T>>
public static <T> Observable.Operator<T,T> rebatch(int n)
Copyright © 2018. All rights reserved.