Movatterモバイル変換

Type Parameters:

T - the type of items emitted by theConnectableObservable

public abstract classConnectableObservable<T>extendsObservable<T>

See Also:

RxJava Wiki: Connectable Observable Operators

• 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
  protected	ConnectableObservable(Observable.OnSubscribe<T> onSubscribe)

• Method Summary

  All Methods Instance Methods Abstract Methods Concrete Methods 

  Modifier and Type	Method and Description
  Observable<T>	autoConnect() Returns an Observable that automatically connects to this ConnectableObservable when the first Subscriber subscribes.
  Observable<T>	autoConnect(int numberOfSubscribers) Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it.
  Observable<T>	autoConnect(int numberOfSubscribers,Action1<? superSubscription> 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.
  Subscription	connect() Instructs theConnectableObservable to begin emitting the items from its underlyingObservable to itsSubscribers.
  abstract void	connect(Action1<? superSubscription> connection) Instructs theConnectableObservable to begin emitting the items from its underlyingObservable to itsSubscribers.
  Observable<T>	refCount() Returns anObservable that stays connected to thisConnectableObservable as 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,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

  • Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

• Constructor Detail

  • ConnectableObservable

    protected ConnectableObservable(Observable.OnSubscribe<T> onSubscribe)

• Method Detail

  • connect

    public final Subscription connect()

    Instructs theConnectableObservable to begin emitting the items from its underlyingObservable to itsSubscribers.

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

    Returns:

    the subscription representing the connection

    See Also:

    ReactiveX documentation: Connect

  • connect

    public abstract void connect(Action1<? superSubscription> connection)

    Instructs theConnectableObservable to begin emitting the items from its underlyingObservable to 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

    See Also:

    ReactiveX documentation: Connect

  • refCount

    public Observable<T> refCount()

    Returns anObservable that stays connected to thisConnectableObservable as long as there is at least one subscription to thisConnectableObservable.

    Returns:

    aObservable

    See Also:

    ReactiveX documentation: RefCount

  • autoConnect

    public Observable<T> autoConnect()

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

    Returns:

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

    Since:

    1.2

  • autoConnect

    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 - the number of subscribers to await before calling connect on the ConnectableObservable. A non-positive value indicates an immediate connection.

    Returns:

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

    Since:

    1.2

  • autoConnect

    public Observable<T> autoConnect(int numberOfSubscribers,Action1<? superSubscription> 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 - the number of subscribers to await before calling connect on the ConnectableObservable. A non-positive value indicates an immediate connection.

    connection - the callback Action1 that will receive the Subscription representing the established 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

    Since:

    1.2