Uses of Interface
io.reactivex.rxjava3.core.Emitter
-
Packages that use Emitter Package Description io.reactivex.rxjava3.core Base reactive classes:Flowable
,Observable
,Single
,Maybe
andCompletable
; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.internal.operators.observable io.reactivex.rxjava3.internal.util -
-
Uses of Emitter in io.reactivex.rxjava3.core
Subinterfaces of Emitter in io.reactivex.rxjava3.core Modifier and Type Interface Description interface
FlowableEmitter<T>
Abstraction over a Reactive StreamsSubscriber
that allows associating a resource with it and exposes the current number of downstream requested amount.interface
ObservableEmitter<T>
Abstraction over an RxJavaObserver
that allows associating a resource with it.Method parameters in io.reactivex.rxjava3.core with type arguments of type Emitter Modifier and Type Method Description static <@NonNull T>
@NonNull Flowable<T>Flowable. generate(@NonNull Consumer<@NonNull Emitter<@NonNull T>> generator)
Returns a cold, synchronous, stateless and backpressure-aware generator of values.static <@NonNull T,@NonNull S>
@NonNull Flowable<T>Flowable. generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiConsumer<@NonNull S,Emitter<@NonNull T>> generator)
Returns a cold, synchronous, stateful and backpressure-aware generator of values.static <@NonNull T,@NonNull S>
@NonNull Flowable<T>Flowable. generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiConsumer<@NonNull S,Emitter<@NonNull T>> generator, @NonNull Consumer<? super @NonNull S> disposeState)
Returns a cold, synchronous, stateful and backpressure-aware generator of values.static <@NonNull T,@NonNull S>
@NonNull Flowable<T>Flowable. generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S,@NonNull Emitter<@NonNull T>,@NonNull S> generator)
Returns a cold, synchronous, stateful and backpressure-aware generator of values.static <@NonNull T,@NonNull S>
@NonNull Flowable<T>Flowable. generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S,@NonNull Emitter<@NonNull T>,@NonNull S> generator, @NonNull Consumer<? super @NonNull S> disposeState)
Returns a cold, synchronous, stateful and backpressure-aware generator of values.static <@NonNull T>
@NonNull Observable<T>Observable. generate(@NonNull Consumer<Emitter<@NonNull T>> generator)
Returns a cold, synchronous and stateless generator of values.static <@NonNull T,@NonNull S>
@NonNull Observable<T>Observable. generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiConsumer<@NonNull S,Emitter<@NonNull T>> generator)
Returns a cold, synchronous and stateful generator of values.static <@NonNull T,@NonNull S>
@NonNull Observable<T>Observable. generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiConsumer<@NonNull S,Emitter<@NonNull T>> generator, @NonNull Consumer<? super @NonNull S> disposeState)
Returns a cold, synchronous and stateful generator of values.static <@NonNull T,@NonNull S>
@NonNull Observable<T>Observable. generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S,Emitter<@NonNull T>,@NonNull S> generator)
Returns a cold, synchronous and stateful generator of values.static <@NonNull T,@NonNull S>
@NonNull Observable<T>Observable. generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S,Emitter<@NonNull T>,@NonNull S> generator, @NonNull Consumer<? super @NonNull S> disposeState)
Returns a cold, synchronous and stateful generator of values. -
Uses of Emitter in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement Emitter Modifier and Type Class Description (package private) static class
FlowableCreate.BaseEmitter<T>
(package private) static class
FlowableCreate.BufferAsyncEmitter<T>
(package private) static class
FlowableCreate.DropAsyncEmitter<T>
(package private) static class
FlowableCreate.ErrorAsyncEmitter<T>
(package private) static class
FlowableCreate.LatestAsyncEmitter<T>
(package private) static class
FlowableCreate.MissingEmitter<T>
(package private) static class
FlowableCreate.NoOverflowBaseAsyncEmitter<T>
(package private) static class
FlowableCreate.SerializedEmitter<T>
Serializes calls to onNext, onError and onComplete.(package private) static class
FlowableGenerate.GeneratorSubscription<T,S>
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type Emitter Modifier and Type Field Description (package private) BiConsumer<S,Emitter<T>>
FlowableInternalHelper.SimpleBiGenerator. consumer
(package private) Consumer<Emitter<T>>
FlowableInternalHelper.SimpleGenerator. consumer
(package private) BiFunction<S,Emitter<T>,S>
FlowableGenerate. generator
(package private) BiFunction<S,? super Emitter<T>,S>
FlowableGenerate.GeneratorSubscription. generator
Methods in io.reactivex.rxjava3.internal.operators.flowable that return types with arguments of type Emitter Modifier and Type Method 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)
Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type Emitter Modifier and Type Method Description S
FlowableInternalHelper.SimpleBiGenerator. apply(S t1, Emitter<T> t2)
S
FlowableInternalHelper.SimpleGenerator. apply(S t1, Emitter<T> t2)
Method parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type Emitter Modifier and Type Method 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 parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type Emitter Constructor Description FlowableGenerate(Supplier<S> stateSupplier, BiFunction<S,Emitter<T>,S> generator, Consumer<? super S> disposeState)
GeneratorSubscription(org.reactivestreams.Subscriber<? super T> actual, BiFunction<S,? super Emitter<T>,S> generator, Consumer<? super S> disposeState, S initialState)
SimpleBiGenerator(BiConsumer<S,Emitter<T>> consumer)
SimpleGenerator(Consumer<Emitter<T>> consumer)
-
Uses of Emitter in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement Emitter Modifier and Type Class Description (package private) static class
ObservableCreate.CreateEmitter<T>
(package private) static class
ObservableCreate.SerializedEmitter<T>
Serializes calls to onNext, onError and onComplete.(package private) static class
ObservableGenerate.GeneratorDisposable<T,S>
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type Emitter Modifier and Type Field Description (package private) BiConsumer<S,Emitter<T>>
ObservableInternalHelper.SimpleBiGenerator. consumer
(package private) Consumer<Emitter<T>>
ObservableInternalHelper.SimpleGenerator. consumer
(package private) BiFunction<S,Emitter<T>,S>
ObservableGenerate. generator
(package private) BiFunction<S,? super Emitter<T>,S>
ObservableGenerate.GeneratorDisposable. generator
Methods in io.reactivex.rxjava3.internal.operators.observable that return types with arguments of type Emitter Modifier and Type Method 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)
Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type Emitter Modifier and Type Method Description S
ObservableInternalHelper.SimpleBiGenerator. apply(S t1, Emitter<T> t2)
S
ObservableInternalHelper.SimpleGenerator. apply(S t1, Emitter<T> t2)
Method parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type Emitter Modifier and Type Method 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 parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type Emitter Constructor Description GeneratorDisposable(Observer<? super T> actual, BiFunction<S,? super Emitter<T>,S> generator, Consumer<? super S> disposeState, S initialState)
ObservableGenerate(Supplier<S> stateSupplier, BiFunction<S,Emitter<T>,S> generator, Consumer<? super S> disposeState)
SimpleBiGenerator(BiConsumer<S,Emitter<T>> consumer)
SimpleGenerator(Consumer<Emitter<T>> consumer)
-
Uses of Emitter in io.reactivex.rxjava3.internal.util
Methods in io.reactivex.rxjava3.internal.util with parameters of type Emitter Modifier and Type Method Description void
AtomicThrowable. tryTerminateConsumer(Emitter<?> consumer)
Tries to terminate this atomic throwable (by swapping in the TERMINATED indicator) and notifies the consumer if there was no error (onComplete) or there was a non-null, non-indicator exception contained before (onError).
-