public final class OperatorReplay<T> extends ConnectableObservable<T>
Observable.Operator<Downstream,Upstream>, Observable.Transformer<T,R>| Modifier and Type | Method and Description |
|---|---|
void |
connect(Consumer<? super Disposable> connection)
Instructs the
ConnectableObservable to begin emitting the items from its underlying
Observable to its Subscribers. |
static <T> ConnectableObservable<T> |
create(Observable<? extends T> source,
int bufferSize)
Creates a replaying ConnectableObservable with a size bound buffer.
|
static <T> ConnectableObservable<T> |
create(Observable<? extends T> source,
long maxAge,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler)
Creates a replaying ConnectableObservable with a time bound buffer.
|
static <T> ConnectableObservable<T> |
create(Observable<? extends T> source,
long maxAge,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler,
int bufferSize)
Creates a replaying ConnectableObservable with a size and time bound buffer.
|
static <T> ConnectableObservable<T> |
createFrom(Observable<? extends T> source)
Creates a replaying ConnectableObservable with an unbounded buffer.
|
static <U,R> Observable<R> |
multicastSelector(Supplier<? extends ConnectableObservable<U>> connectableFactory,
Function<? super Observable<U>,? extends org.reactivestreams.Publisher<R>> selector)
Given a connectable observable factory, it multicasts over the generated
ConnectableObservable via a selector function.
|
static <T> ConnectableObservable<T> |
observeOn(ConnectableObservable<T> co,
Scheduler scheduler)
Child Subscribers will observe the events of the ConnectableObservable on the
specified scheduler.
|
autoConnect, autoConnect, autoConnect, connect, refCountall, amb, amb, ambWith, any, asObservable, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferSize, cache, cache, cast, collect, collectInto, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, compose, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concatArray, concatArray, concatMap, concatMap, concatMapIterable, concatMapIterable, concatWith, contains, count, create, debounce, debounce, debounce, defaultIfEmpty, defer, delay, delay, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, delaySubscription, dematerialize, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, doOnCancel, doOnComplete, doOnEach, doOnEach, doOnError, doOnLifecycle, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elementAt, elementAt, empty, endWith, endWith, endWith, endWithArray, error, error, filter, finallyDo, first, first, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMapIterable, flatMapIterable, flatMapIterable, forEach, forEachWhile, forEachWhile, forEachWhile, fromArray, fromCallable, fromFuture, fromFuture, fromFuture, fromFuture, fromIterable, fromPublisher, generate, generate, generate, generate, generate, groupBy, groupBy, groupBy, groupBy, groupBy, ignoreElements, interval, interval, interval, interval, intervalRange, intervalRange, isEmpty, just, just, just, just, just, just, just, just, just, last, last, lift, map, materialize, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, nest, never, observeOn, observeOn, observeOn, ofType, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureLatest, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onErrorReturnValue, onExceptionResumeNext, publish, publish, publish, publish, range, reduce, reduce, reduceWith, repeat, repeat, repeatUntil, repeatWhen, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, retry, retry, retry, retry, retry, retryUntil, retryWhen, safeSubscribe, sample, sample, sample, scan, scan, scanWith, sequenceEqual, sequenceEqual, sequenceEqual, sequenceEqual, serialize, share, single, single, skip, skip, skipLast, skipLast, skipLast, skipLast, skipLast, skipLast, skipUntil, skipWhile, startWith, startWith, startWith, startWithArray, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeOn, switchIfEmpty, switchMap, switchMap, switchOnNext, switchOnNext, take, take, takeFirst, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeUntil, takeUntil, takeWhile, throttleFirst, throttleFirst, throttleLast, throttleLast, throttleWithTimeout, throttleWithTimeout, timeInterval, timeInterval, timeInterval, timeInterval, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, timestamp, timestamp, timestamp, timestamp, to, toBlocking, toList, toList, toList, toMap, toMap, toMap, toMultimap, toMultimap, toMultimap, toMultimap, toNbpObservable, toSingle, toSortedList, toSortedList, toSortedList, toSortedList, unsafeSubscribe, unsubscribeOn, using, using, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipArray, zipIterable, zipWith, zipWith, zipWith, zipWithpublic static <U,R> Observable<R> multicastSelector(Supplier<? extends ConnectableObservable<U>> connectableFactory, Function<? super Observable<U>,? extends org.reactivestreams.Publisher<R>> selector)
U - the connectable observable typeR - the result typeconnectableFactory - selector - public static <T> ConnectableObservable<T> observeOn(ConnectableObservable<T> co, Scheduler scheduler)
T - the value typeco - scheduler - public static <T> ConnectableObservable<T> createFrom(Observable<? extends T> source)
T - the value typesource - public static <T> ConnectableObservable<T> create(Observable<? extends T> source, int bufferSize)
T - the value typesource - bufferSize - public static <T> ConnectableObservable<T> create(Observable<? extends T> source, long maxAge, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
T - the value typesource - maxAge - unit - scheduler - public static <T> ConnectableObservable<T> create(Observable<? extends T> source, long maxAge, java.util.concurrent.TimeUnit unit, Scheduler scheduler, int bufferSize)
T - the value typesource - maxAge - unit - scheduler - bufferSize - public void connect(Consumer<? super Disposable> connection)
ConnectableObservableConnectableObservable to begin emitting the items from its underlying
Observable to its Subscribers.connect in class ConnectableObservable<T>connection - the action that receives the connection subscription before the subscription to source happens
allowing the caller to synchronously disconnect a synchronous source