Class ConnectableObservable<T>
- java.lang.Object
-
- rx.Observable
<T> -
- rx
.observables .ConnectableObservable<T>
- rx
- rx.Observable
-
- Type Parameters:
-
T- the type of items emitted by theConnectableObservable
- Direct Known Subclasses:
-
OperatorMulticast
, OperatorPublish
public abstract class ConnectableObservable<T> extends Observable
<T> AConnectableObservableresembles an ordinaryObservable, except that it does not begin emitting items when it is subscribed to, but only when itsconnect()method is called. In this way you can wait for all intendedSubscribers toObservableto the.subscribe() Observablebefore theObservablebegins emitting items.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class rx
.Observable Observable.OnSubscribe <T>, Observable .Operator <R ,T>, Observable .Transformer <T ,R>
-
-
Constructor Summary
Constructors
Modifier Constructor and Description protectedConnectableObservable(Observable.OnSubscribe <T> onSubscribe)
-
Method Summary
Modifier and Type Method and Description Subscriptionconnect()Instructs theConnectableObservableto begin emitting the items from its underlyingObservableto itsSubscribers.abstract voidconnect(Action1<? super Subscription > connection) Instructs theConnectableObservableto begin emitting the items from its underlyingObservableto itsSubscribers.Observable<T> refCount()Returns anObservablethat stays connected to thisConnectableObservableas long as there is at least one subscription to thisConnectableObservable.-
Methods inherited from class rx
.Observable all, 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, concatMap, 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, doOnSubscribe, doOnTerminate, doOnUnsubscribe, elementAt, elementAtOrDefault, empty, error, exists, filter, finallyDo, first, first, firstOrDefault, firstOrDefault, flatMap, flatMap, flatMap, flatMapIterable, flatMapIterable, forEach, forEach, forEach, from, from, from, from, from, groupBy, groupBy, groupJoin, ignoreElements, 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, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, nest, never, observeOn, ofType, onBackpressureBuffer, onBackpressureDrop, 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, switchMap, switchOnNext, take, take, take, takeFirst, takeLast, takeLast, takeLast, takeLast, takeLast, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, 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, toSortedList, toSortedList, unsafeSubscribe, unsubscribeOn, using, window, window, window, window, window, window, window, window, window, window, window, window, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith, zipWith
-
-
-
-
Constructor Detail
ConnectableObservable
protected ConnectableObservable(Observable
.OnSubscribe <T> onSubscribe)
-
Method Detail
connect
public final Subscription
connect() Instructs theConnectableObservableto begin emitting the items from its underlyingObservableto itsSubscribers.To disconnect from a synchronous source, use the
connect(rx.functions.Action1)method.- Returns:
- the subscription representing the connection
connect
public abstract void connect(Action1
<? super Subscription > connection) Instructs theConnectableObservableto begin emitting the items from its underlyingObservableto itsSubscribers.- Parameters:
-
connection- the action that receives the connection subscription before the subscription to source happens allowing the caller to synchronously disconnect a synchronous source
refCount
public Observable
<T> refCount() Returns anObservablethat stays connected to thisConnectableObservableas long as there is at least one subscription to thisConnectableObservable.- Returns:
-
a
Observable
-