Packages that use AbstractOnSubscribe.SubscriptionState

• Uses of AbstractOnSubscribe.SubscriptionState in rx.observables

  Methods in with parameters of type

  Modifier and Type	Method and Description
  protected abstract void	AbstractOnSubscribe.next(AbstractOnSubscribe.SubscriptionState<T,S> state) Override this method to create an emission state-machine.

  Method parameters in rx.observables with type arguments of type AbstractOnSubscribe.SubscriptionState

  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.