static <S,T> AsyncOnSubscribe<S,T> |
AsyncOnSubscribe.createSingleState(Func0<? extends S> generator,
Action3<? super S,java.lang.Long,? super Observer<Observable<? extends T>>> next) |
Generates a synchronous AsyncOnSubscribe that calls the provided next
function to generate data to downstream subscribers.
|
static <S,T> AsyncOnSubscribe<S,T> |
AsyncOnSubscribe.createSingleState(Func0<? extends S> generator,
Action3<? super S,java.lang.Long,? super Observer<Observable<? extends T>>> next,
Action1<? super S> onUnsubscribe) |
Generates a synchronous AsyncOnSubscribe that calls the provided next
function to generate data to downstream subscribers.
|
static <S,T> AsyncOnSubscribe<S,T> |
AsyncOnSubscribe.createStateful(Func0<? extends S> generator,
Func3<? super S,java.lang.Long,? super Observer<Observable<? extends T>>,? extends S> next) |
Generates a synchronous AsyncOnSubscribe that calls the provided next
function to generate data to downstream subscribers.
|
static <S,T> AsyncOnSubscribe<S,T> |
AsyncOnSubscribe.createStateful(Func0<? extends S> generator,
Func3<? super S,java.lang.Long,? super Observer<Observable<? extends T>>,? extends S> next,
Action1<? super S> onUnsubscribe) |
Generates a synchronous AsyncOnSubscribe that calls the provided next
function to generate data to downstream subscribers.
|
static <T> AsyncOnSubscribe<java.lang.Void,T> |
AsyncOnSubscribe.createStateless(Action2<java.lang.Long,? super Observer<Observable<? extends T>>> next) |
Generates a synchronous AsyncOnSubscribe that calls the provided next
function to generate data to downstream subscribers.
|
static <T> AsyncOnSubscribe<java.lang.Void,T> |
AsyncOnSubscribe.createStateless(Action2<java.lang.Long,? super Observer<Observable<? extends T>>> next,
Action0 onUnsubscribe) |
Generates a synchronous AsyncOnSubscribe that calls the provided next
function to generate data to downstream subscribers.
|