Packages that use ConnectableObservable

• Uses of ConnectableObservable in rx

  Methods in rx that return ConnectableObservable

  Modifier and Type	Method and Description
  ConnectableObservable<T>	Observable.publish() Returns a ConnectableObservable, which is a variety of Observable that waits until its connect method is called before it begins emitting items to those Observers that have subscribed to it.
  ConnectableObservable<T>	Observable.replay() Returns a ConnectableObservable that shares a single subscription to the underlying Observable that will replay all of its items and notifications to any future Observer.
  ConnectableObservable<T>	Observable.replay(int bufferSize) Returns a ConnectableObservable that shares a single subscription to the source Observable that replays at most bufferSize items emitted by that Observable.
  ConnectableObservable<T>	Observable.replay(int bufferSize, long time, TimeUnit unit) Returns a ConnectableObservable that shares a single subscription to the source Observable and replays at most bufferSize items that were emitted during a specified time window.
  ConnectableObservable<T>	Observable.replay(int bufferSize, long time, TimeUnit unit, Scheduler scheduler) Returns a ConnectableObservable that shares a single subscription to the source Observable and that replays a maximum of bufferSize items that are emitted within a specified time window.
  ConnectableObservable<T>	Observable.replay(int bufferSize, Scheduler scheduler) Returns a ConnectableObservable that shares a single subscription to the source Observable and replays at most bufferSize items emitted by that Observable.
  ConnectableObservable<T>	Observable.replay(long time, TimeUnit unit) Returns a ConnectableObservable that shares a single subscription to the source Observable and replays all items emitted by that Observable within a specified time window.
  ConnectableObservable<T>	Observable.replay(long time, TimeUnit unit, Scheduler scheduler) Returns a ConnectableObservable that shares a single subscription to the source Observable and replays all items emitted by that Observable within a specified time window.
  ConnectableObservable<T>	Observable.replay(Scheduler scheduler) Returns a ConnectableObservable that shares a single subscription to the source Observable that will replay all of its items and notifications to any future Observer on the given Scheduler.

• Uses of ConnectableObservable in rx.internal.operators

  Subclasses of in

  Modifier and Type	Class and Description
  class	OperatorMulticast<T,R> Shares a single subscription to a source through a Subject.
  class	OperatorPublish<T>

  Methods in that return

  Modifier and Type	Method and Description
  static <T> ConnectableObservable<T>	OperatorPublish.create(Observable<? extends T> source)

  Constructors in rx.internal.operators with parameters of type ConnectableObservable

  Constructor and Description
  	OnSubscribeRefCount(ConnectableObservable<? extends T> source) Constructor.