rxjava 1.3.8 · rx.observables.ConnectableObservable

Access	Constructor and Description
protected	ConnectableObservable(Observable.OnSubscribe<T> onSubscribe)

Method Summary

Modifier and Type	Method and Description
public Observable<T>	Returns: an Observable that automatically connects to this ConnectableObservable when the first Subscriber subscribes autoConnect() Returns an Observable that automatically connects to this ConnectableObservable when the first Subscriber subscribes.
public Observable<T>	Returns: an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it autoConnect(int the number of subscribers to await before calling connect on the ConnectableObservable. A non-positive value indicates an immediate connection. numberOfSubscribers) Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it.
public Observable<T>	Returns: an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it and calls the specified callback with the Subscription associated with the established connection autoConnect(int the number of subscribers to await before calling connect on the ConnectableObservable. A non-positive value indicates an immediate connection. numberOfSubscribers, Action1<? super Subscription> the callback Action1 that will receive the Subscription representing the established connection connection) Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it and calls the specified callback with the Subscription associated with the established connection.
public final Subscription	Returns: the subscription representing the connection connect() Instructs the `ConnectableObservable` to begin emitting the items from its underlying `Observable` to its `Subscriber`s.
public abstract void	connect(Action1<? super Subscription> the action that receives the connection subscription before the subscription to source happens allowing the caller to synchronously disconnect a synchronous source connection) Instructs the `ConnectableObservable` to begin emitting the items from its underlying `Observable` to its `Subscriber`s.
public Observable<T>	Returns: a `Observable` refCount() Returns an `Observable` that stays connected to this `ConnectableObservable` as long as there is at least one subscription to this `ConnectableObservable`.

Inherited from 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 cacheWithInitialCapacity cast collect combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatestDelayError compose concat concat concat concat concat concat concat concat concat concat concatDelayError concatDelayError concatDelayError concatDelayError concatDelayError concatDelayError concatDelayError concatDelayError concatDelayError concatDelayError concatEager concatEager concatEager concatEager concatEager concatEager concatEager concatEager concatEager concatEager concatEager concatEager concatMap concatMapDelayError concatMapEager concatMapEager concatMapEager concatMapIterable concatWith contains count countLong create create create create debounce debounce debounce defaultIfEmpty defer delay delay delay delay delaySubscription delaySubscription delaySubscription delaySubscription dematerialize distinct distinct distinctUntilChanged distinctUntilChanged distinctUntilChanged doAfterTerminate doOnCompleted doOnEach doOnEach doOnError doOnNext doOnRequest doOnSubscribe doOnTerminate doOnUnsubscribe elementAt elementAtOrDefault empty error exists filter finallyDo first first firstOrDefault firstOrDefault flatMap flatMap flatMap flatMap flatMap flatMap flatMapCompletable flatMapCompletable flatMapCompletable flatMapIterable flatMapIterable flatMapIterable flatMapIterable flatMapSingle flatMapSingle flatMapSingle forEach forEach forEach from from from from from fromCallable groupBy groupBy 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 mergeDelayError mergeDelayError mergeWith nest never observeOn observeOn observeOn observeOn ofType onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureDrop onBackpressureDrop onBackpressureLatest onErrorResumeNext onErrorResumeNext onErrorReturn onExceptionResumeNext onTerminateDetach publish publish range range rebatchRequests 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 sorted sorted startWith startWith startWith startWith startWith startWith startWith startWith startWith startWith startWith subscribe subscribe subscribe subscribe subscribe subscribe subscribeOn subscribeOn switchIfEmpty switchMap switchMapDelayError switchOnNext switchOnNextDelayError take take take takeFirst takeLast takeLast takeLast takeLast takeLast takeLastBuffer takeLastBuffer takeLastBuffer takeLastBuffer takeLastBuffer takeUntil takeUntil takeWhile test test throttleFirst throttleFirst throttleLast throttleLast throttleWithTimeout throttleWithTimeout timeInterval timeInterval timeout timeout timeout timeout timeout timeout timeout timeout timer timer timer timer timestamp timestamp to toBlocking toCompletable toList toMap toMap toMap toMultimap toMultimap toMultimap toMultimap toSingle toSortedList toSortedList toSortedList toSortedList unsafeCreate unsafeSubscribe unsubscribeOn using using window window window window window window window window window window window window withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom zip zip zip zip zip zip zip zip zip zip zip zipWith zipWith

Constructor Detail

ConnectableObservable	back to summary
protected ConnectableObservable(Observable.OnSubscribe<T> onSubscribe)

Method Detail

autoConnect	back to summary
public Observable<T> autoConnect() Returns an Observable that automatically connects to this ConnectableObservable when the first Subscriber subscribes. Returns:Observable<T> an Observable that automatically connects to this ConnectableObservable when the first Subscriber subscribes Since 1.2

autoConnect

back to summary

public Observable<T> autoConnect()

Returns an Observable that automatically connects to this ConnectableObservable when the first Subscriber subscribes.

Returns:Observable<T>: an Observable that automatically connects to this ConnectableObservable when the first Subscriber subscribes
Since: 1.2

autoConnect	back to summary
public Observable<T> autoConnect(int numberOfSubscribers) Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it. Parameters numberOfSubscribers:int the number of subscribers to await before calling connect on the ConnectableObservable. A non-positive value indicates an immediate connection. Returns:Observable<T> an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it Since 1.2

autoConnect

back to summary

public Observable<T> autoConnect(int numberOfSubscribers)

Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it.

Parameters

numberOfSubscribers:int: the number of subscribers to await before calling connect on the ConnectableObservable. A non-positive value indicates an immediate connection.

Returns:Observable<T>

an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it

Since

1.2

autoConnect	back to summary
public Observable<T> autoConnect(int numberOfSubscribers, Action1<? super Subscription> connection) Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it and calls the specified callback with the Subscription associated with the established connection. Parameters numberOfSubscribers:int the number of subscribers to await before calling connect on the ConnectableObservable. A non-positive value indicates an immediate connection. connection:Action1<? super Subscription> the callback Action1 that will receive the Subscription representing the established connection Returns:Observable<T> an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it and calls the specified callback with the Subscription associated with the established connection Since 1.2

autoConnect

back to summary

public Observable<T> autoConnect(int numberOfSubscribers, Action1<? super Subscription> connection)

Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it and calls the specified callback with the Subscription associated with the established connection.

Parameters

numberOfSubscribers:int: the number of subscribers to await before calling connect on the ConnectableObservable. A non-positive value indicates an immediate connection.
connection:Action1<? super Subscription>: the callback Action1 that will receive the Subscription representing the established connection

Returns:Observable<T>

an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it and calls the specified callback with the Subscription associated with the established connection

Since

1.2

connect back to summary

connect	back to summary
public final Subscription connect() Instructs the `ConnectableObservable` to begin emitting the items from its underlying `Observable` to its `Subscriber`s. To disconnect from a synchronous source, use the `connect(rx.functions.Action1)` method. Returns:Subscription the subscription representing the connection See Also ReactiveX documentation: Connect

public final Subscription connect()

Instructs the ConnectableObservable to begin emitting the items from its underlying Observable to its Subscribers.

To disconnect from a synchronous source, use the connect(rx.functions.Action1) method.

Returns:Subscription: the subscription representing the connection
See Also: ReactiveX documentation: Connect

connect back to summary

connect	back to summary
public abstract void connect(Action1<? super Subscription> connection) Instructs the `ConnectableObservable` to begin emitting the items from its underlying `Observable` to its `Subscriber`s. Parameters connection:Action1<? super Subscription> the action that receives the connection subscription before the subscription to source happens allowing the caller to synchronously disconnect a synchronous source See Also ReactiveX documentation: Connect

public abstract void connect(Action1<? super Subscription> connection)

Instructs the ConnectableObservable to begin emitting the items from its underlying Observable to its Subscribers.

Parameters

connection:Action1<? super Subscription>: the action that receives the connection subscription before the subscription to source happens allowing the caller to synchronously disconnect a synchronous source

See Also

ReactiveX documentation: Connect

refCount back to summary

refCount	back to summary
public Observable<T> refCount() Returns an `Observable` that stays connected to this `ConnectableObservable` as long as there is at least one subscription to this `ConnectableObservable`. Returns:Observable<T> a `Observable` See Also ReactiveX documentation: RefCount

public Observable<T> refCount()

Returns an Observable that stays connected to this ConnectableObservable as long as there is at least one subscription to this ConnectableObservable.

Returns:Observable<T>: a Observable
See Also: ReactiveX documentation: RefCount

public abstract Class ConnectableObservable<T>

Constructor Summary

Method Summary

Constructor Detail

Method Detail