Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.observable |
Modifier and Type | Interface and Description |
---|---|
interface |
FlowableEmitter<T>
Abstraction over a Reactive Streams
Subscriber that allows associating
a resource with it and exposes the current number of downstream
requested amount. |
interface |
ObservableEmitter<T>
Abstraction over an RxJava
Observer that allows associating
a resource with it. |
Modifier and Type | Method and Description |
---|---|
static <T,S> Observable<T> |
Observable.generate(Callable<S> initialState,
BiConsumer<S,Emitter<T>> generator)
Returns a cold, synchronous and stateful generator of values.
|
static <T,S> Flowable<T> |
Flowable.generate(Callable<S> initialState,
BiConsumer<S,Emitter<T>> generator)
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
|
static <T,S> Observable<T> |
Observable.generate(Callable<S> initialState,
BiConsumer<S,Emitter<T>> generator,
Consumer<? super S> disposeState)
Returns a cold, synchronous and stateful generator of values.
|
static <T,S> Flowable<T> |
Flowable.generate(Callable<S> initialState,
BiConsumer<S,Emitter<T>> generator,
Consumer<? super S> disposeState)
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
|
static <T,S> Observable<T> |
Observable.generate(Callable<S> initialState,
BiFunction<S,Emitter<T>,S> generator)
Returns a cold, synchronous and stateful generator of values.
|
static <T,S> Flowable<T> |
Flowable.generate(Callable<S> initialState,
BiFunction<S,Emitter<T>,S> generator)
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
|
static <T,S> Observable<T> |
Observable.generate(Callable<S> initialState,
BiFunction<S,Emitter<T>,S> generator,
Consumer<? super S> disposeState)
Returns a cold, synchronous and stateful generator of values.
|
static <T,S> Flowable<T> |
Flowable.generate(Callable<S> initialState,
BiFunction<S,Emitter<T>,S> generator,
Consumer<? super S> disposeState)
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
|
static <T> Observable<T> |
Observable.generate(Consumer<Emitter<T>> generator)
Returns a cold, synchronous and stateless generator of values.
|
static <T> Flowable<T> |
Flowable.generate(Consumer<Emitter<T>> generator)
Returns a cold, synchronous, stateless and backpressure-aware generator of values.
|
Modifier and Type | Method and Description |
---|---|
static <T,S> BiFunction<S,Emitter<T>,S> |
FlowableInternalHelper.simpleBiGenerator(BiConsumer<S,Emitter<T>> consumer) |
static <T,S> BiFunction<S,Emitter<T>,S> |
FlowableInternalHelper.simpleGenerator(Consumer<Emitter<T>> consumer) |
Modifier and Type | Method and Description |
---|---|
static <T,S> BiFunction<S,Emitter<T>,S> |
FlowableInternalHelper.simpleBiGenerator(BiConsumer<S,Emitter<T>> consumer) |
static <T,S> BiFunction<S,Emitter<T>,S> |
FlowableInternalHelper.simpleGenerator(Consumer<Emitter<T>> consumer) |
Constructor and Description |
---|
FlowableGenerate(Callable<S> stateSupplier,
BiFunction<S,Emitter<T>,S> generator,
Consumer<? super S> disposeState) |
Modifier and Type | Method and Description |
---|---|
static <T,S> BiFunction<S,Emitter<T>,S> |
ObservableInternalHelper.simpleBiGenerator(BiConsumer<S,Emitter<T>> consumer) |
static <T,S> BiFunction<S,Emitter<T>,S> |
ObservableInternalHelper.simpleGenerator(Consumer<Emitter<T>> consumer) |
Modifier and Type | Method and Description |
---|---|
static <T,S> BiFunction<S,Emitter<T>,S> |
ObservableInternalHelper.simpleBiGenerator(BiConsumer<S,Emitter<T>> consumer) |
static <T,S> BiFunction<S,Emitter<T>,S> |
ObservableInternalHelper.simpleGenerator(Consumer<Emitter<T>> consumer) |
Constructor and Description |
---|
ObservableGenerate(Callable<S> stateSupplier,
BiFunction<S,Emitter<T>,S> generator,
Consumer<? super S> disposeState) |
Copyright © 2019. All rights reserved.