public final class OperatorReplay<T> extends ConnectableObservable<T>
Observable.OnSubscribe <T>, Observable.Operator <R,T>, Observable.Transformer <T,R> | Modifier and Type | Method and Description |
|---|---|
void |
connect(Action1
Instructs the
ConnectableObservable to begin emitting the items from its underlying
Observable to its
Subscribers.
|
static <T> ConnectableObservable |
create(Observable
Creates a replaying ConnectableObservable with an unbounded buffer.
|
static <T> ConnectableObservable |
create(Observable
Creates a replaying ConnectableObservable with a size bound buffer.
|
static <T> ConnectableObservable |
create(Observable
Creates a replaying ConnectableObservable with a time bound buffer.
|
static <T> ConnectableObservable |
create(Observable
Creates a replaying ConnectableObservable with a size and time bound buffer.
|
static <T |
multicastSelector(Func0
Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.
|
static <T> ConnectableObservable |
observeOn(ConnectableObservable
Child Subscribers will observe the events of the ConnectableObservable on the specified scheduler.
|
autoConnect, autoConnect, autoConnect, connect, refCountall, amb, amb, amb, amb, amb, amb, amb, amb, amb, ambWith, asObservable, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, cache, cache, cast, collect, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, compose, concat, concat, concat, concat, concat, concat, concat, concat, concat, concatEager, concatEager, concatEager, concatEager, concatEager, concatEager, concatEager, concatEager, concatEager, concatEager, concatEager, concatEager, concatMap, concatMapEager, concatMapEager, concatWith, contains, count, countLong, create, debounce, debounce, debounce, defaultIfEmpty, defer, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, dematerialize, distinct, distinct, distinctUntilChanged, distinctUntilChanged, doOnCompleted, doOnEach, doOnEach, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, doOnUnsubscribe, elementAt, elementAtOrDefault, empty, error, exists, extend, filter, finallyDo, first, first, firstOrDefault, firstOrDefault, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMapIterable, flatMapIterable, forEach, forEach, forEach, from, from, from, from, from, fromCallable, groupBy, groupBy, groupJoin, ignoreElements, interval, interval, interval, interval, isEmpty, join, just, just, just, just, just, just, just, just, just, just, last, last, lastOrDefault, lastOrDefault, lift, limit, map, materialize, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, nest, never, observeOn, ofType, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureLatest, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onExceptionResumeNext, publish, publish, range, range, reduce, reduce, repeat, repeat, repeat, repeat, repeatWhen, repeatWhen, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, retry, retry, retry, retryWhen, retryWhen, sample, sample, sample, scan, scan, sequenceEqual, sequenceEqual, serialize, share, single, single, singleOrDefault, singleOrDefault, skip, skip, skip, skipLast, skipLast, skipLast, skipUntil, skipWhile, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, switchIfEmpty, switchMap, switchOnNext, take, take, take, takeFirst, takeLast, takeLast, takeLast, takeLast, takeLast, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeUntil, takeUntil, takeWhile, throttleFirst, throttleFirst, throttleLast, throttleLast, throttleWithTimeout, throttleWithTimeout, timeInterval, timeInterval, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, timer, timer, timestamp, timestamp, toBlocking, toList, toMap, toMap, toMap, toMultimap, toMultimap, toMultimap, toMultimap, toSingle, toSortedList, toSortedList, toSortedList, toSortedList, unsafeSubscribe, unsubscribeOn, using, using, window, window, window, window, window, window, window, window, window, window, window, window, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith, zipWithpublic static <T,U ,R> Observable <R> multicastSelector(Func0 <? extends ConnectableObservable <U>> connectableFactory, Func1 <? super Observable <U> ,? extends Observable <R>> selector)
connectableFactory -
selector -
public static <T> ConnectableObservable<T> observeOn(ConnectableObservable <T> co, Scheduler scheduler)
co -
scheduler -
public static <T> ConnectableObservable<T> create(Observable <? extends T> source)
source -
public static <T> ConnectableObservable<T> create(Observable <? extends T> source, int bufferSize)
source -
bufferSize -
public static <T> ConnectableObservable<T> create(Observable <? extends T> source, long maxAge, TimeUnit unit, Scheduler scheduler)
source -
maxAge -
unit -
scheduler -
public static <T> ConnectableObservable<T> create(Observable <? extends T> source, long maxAge, TimeUnit unit, Scheduler scheduler, int bufferSize)
source -
maxAge -
unit -
scheduler -
bufferSize -
public void connect(Action1<? super Subscription > connection)
ConnectableObservable
ConnectableObservable 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