public final class OperatorSwitchMap<T,R> extends java.lang.Object implements Observable.Operator<R,T>
| Constructor and Description |
|---|
OperatorSwitchMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int bufferSize) |
| Modifier and Type | Method and Description |
|---|---|
org.reactivestreams.Subscriber<? super T> |
apply(org.reactivestreams.Subscriber<? super R> t) |