Packages that use AbstractOnSubscribe

• Uses of AbstractOnSubscribe in rx.observables

  Methods in rx.observables that return AbstractOnSubscribe

  Modifier and Type	Method and Description
  static <T,S> AbstractOnSubscribe<T,S>	AbstractOnSubscribe.create(Action1<AbstractOnSubscribe.SubscriptionState<T,S>> next) Creates an AbstractOnSubscribe instance which calls the provided next action.
  static <T,S> AbstractOnSubscribe<T,S>	AbstractOnSubscribe.create(Action1<AbstractOnSubscribe.SubscriptionState<T,S>> next, Func1<? super Subscriber<? super T>,? extends S> onSubscribe) Creates an AbstractOnSubscribe instance which creates a custom state with the onSubscribe function and calls the provided next action.
  static <T,S> AbstractOnSubscribe<T,S>	AbstractOnSubscribe.create(Action1<AbstractOnSubscribe.SubscriptionState<T,S>> next, Func1<? super Subscriber<? super T>,? extends S> onSubscribe, Action1<? super S> onTerminated) Creates an AbstractOnSubscribe instance which creates a custom state with the onSubscribe function, calls the provided next action and calls the onTerminated action to release the state when its no longer needed.