Packages that use Observable.OnSubscribe

• Uses of Observable.OnSubscribe in rx

  Methods in with parameters of type

  Modifier and Type	Method and Description
  static <T> Observable<T>	Observable.create(Observable.OnSubscribe<T> f) Returns an Observable that will execute the specified function when a Subscriber subscribes to it.

  Constructors in rx with parameters of type Observable.OnSubscribe

  Constructor and Description
  	Observable(Observable.OnSubscribe<T> f) Creates an Observable with a Function to execute when it is subscribed to.

• Uses of Observable.OnSubscribe in rx.internal.operators

  Classes in that implement

  Modifier and Type	Class and Description
  class	OnSubscribeAmb<T> Given multiple Observables, propagates the one that first emits an item.
  class	OnSubscribeCache<T> This method has similar behavior to Observable.replay() except that this auto-subscribes to the source Observable rather than returning a connectable Observable.
  class	OnSubscribeCombineLatest<T,R> Returns an Observable that combines the emissions of multiple source observables.
  class	OnSubscribeDefer<T> Do not create the Observable until an Observer subscribes; create a fresh Observable on each subscription.
  class	OnSubscribeDelaySubscription<T> Delays the subscription to the source by the given amount, running on the given scheduler.
  class	OnSubscribeDelaySubscriptionWithSelector<T,U> Delays the subscription until the Observable emits an event.
  class	OnSubscribeFromIterable<T> Converts an Iterable sequence into an Observable.
  class	OnSubscribeGroupJoin<T1,T2,D1,D2,R> Corrrelates two sequences when they overlap and groups the results.
  class	OnSubscribeJoin<TLeft,TRight,TLeftDuration,TRightDuration,R> Correlates the elements of two sequences based on overlapping durations.
  class	OnSubscribeMulticastSelector<TInput,TIntermediate,TResult> Returns an observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a selector function.
  class	OnSubscribeRange Emit ints from start to end inclusive.
  class	OnSubscribeRedo<T>
  class	OnSubscribeRefCount<T> Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence.
  class	OnSubscribeTimerOnce Timer that emits a single 0L and completes after the specified time.
  class	OnSubscribeTimerPeriodically Emit 0L after the initial period and ever increasing number after each period.
  class	OnSubscribeUsing<T,Resource> Constructs an observable sequence that depends on a resource object.

  Methods in that return

  Modifier and Type	Method and Description
  static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Iterable<? extends Observable<? extends T>> sources) Given a set of Observables, propagates the one that first emits an item.
  static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2) Given two Observables, propagates the one that first emits an item.
  static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3) Given three Observables, propagates the one that first emits an item.
  static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4) Given four Observables, propagates the one that first emits an item.
  static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5) Given five Observables, propagates the one that first emits an item.
  static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6) Given six Observables, propagates the one that first emits an item.
  static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7) Given seven Observables, propagates the one that first emits an item.
  static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8) Given eight Observables, propagates the one that first emits an item.
  static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8, Observable<? extends T> o9) Given nine Observables, propagates the one that first emits an item.
  static <T> Observable.OnSubscribe<T>	OperatorReplay.subscriberOf(Observable<T> target) Return an OnSubscribeFunc which delegates the subscription to the given observable.
  static <T> Observable.OnSubscribe<T>	OnSubscribeToObservableFuture.toObservableFuture(Future<? extends T> that)
  static <T> Observable.OnSubscribe<T>	OnSubscribeToObservableFuture.toObservableFuture(Future<? extends T> that, long time, TimeUnit unit)

  Constructors in rx.internal.operators with parameters of type Observable.OnSubscribe

  Constructor and Description
  	SubjectWrapper(Observable.OnSubscribe<T> func, Subject<T,T> subject)

• Uses of Observable.OnSubscribe in rx.observables

  Methods in with parameters of type

  Modifier and Type	Method and Description
  static <K,T> GroupedObservable<K,T>	GroupedObservable.create(K key, Observable.OnSubscribe<T> f) Returns an Observable that will execute the specified function when a Subscriber subscribes to it.

  Constructors in rx.observables with parameters of type Observable.OnSubscribe

  Constructor and Description
  	ConnectableObservable(Observable.OnSubscribe<T> onSubscribe)
  	GroupedObservable(K key, Observable.OnSubscribe<T> onSubscribe)

• Uses of Observable.OnSubscribe in rx.plugins

  Methods in that return

  Modifier and Type	Method and Description
  <T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onCreate(Observable.OnSubscribe<T> f) Invoked during the construction by Observable.create(OnSubscribe)
  <T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onSubscribeStart(Observable<? extends T> observableInstance, Observable.OnSubscribe<T> onSubscribe) Invoked before Observable.subscribe(rx.Subscriber) is about to be executed.

  Methods in rx.plugins with parameters of type Observable.OnSubscribe

  Modifier and Type	Method and Description
  <T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onCreate(Observable.OnSubscribe<T> f) Invoked during the construction by Observable.create(OnSubscribe)
  <T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onSubscribeStart(Observable<? extends T> observableInstance, Observable.OnSubscribe<T> onSubscribe) Invoked before Observable.subscribe(rx.Subscriber) is about to be executed.

• Uses of Observable.OnSubscribe in rx.subjects

  Constructors in rx.subjects with parameters of type Observable.OnSubscribe

  Constructor and Description
  	AsyncSubject(Observable.OnSubscribe<T> onSubscribe, rx.subjects.SubjectSubscriptionManager<T> state)
  	BehaviorSubject(Observable.OnSubscribe<T> onSubscribe, rx.subjects.SubjectSubscriptionManager<T> state)
  	PublishSubject(Observable.OnSubscribe<T> onSubscribe, rx.subjects.SubjectSubscriptionManager<T> state)
  	Subject(Observable.OnSubscribe<R> onSubscribe)
  	TestSubject(Observable.OnSubscribe<T> onSubscribe, rx.subjects.SubjectSubscriptionManager<T> state, TestScheduler scheduler)