Package | Description |
---|---|
rx.observables |
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. |
Copyright © 2015. All Rights Reserved.