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 and Completable; 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 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.

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 final class	FlowableCreate.BufferAsyncEmitter<T>
(package private) static final class	FlowableCreate.DropAsyncEmitter<T>
(package private) static final class	FlowableCreate.ErrorAsyncEmitter<T>
(package private) static final class	FlowableCreate.LatestAsyncEmitter<T>
(package private) static final class	FlowableCreate.MissingEmitter<T>
(package private) static class	FlowableCreate.NoOverflowBaseAsyncEmitter<T>
(package private) static final class	FlowableCreate.SerializedEmitter<T>	Serializes calls to onNext, onError and onComplete.
(package private) static final 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) final BiConsumer<S,Emitter<T>>	FlowableInternalHelper.SimpleBiGenerator.consumer
(package private) final Consumer<Emitter<T>>	FlowableInternalHelper.SimpleGenerator.consumer
(package private) final BiFunction<S,Emitter<T>,S>	FlowableGenerate.generator
(package private) final 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

Modifier	Constructor	Description
	FlowableGenerate(Supplier<S> stateSupplier, BiFunction<S,Emitter<T>,S> generator, Consumer<? super S> disposeState)
(package private)	GeneratorSubscription(org.reactivestreams.Subscriber<? super T> actual, BiFunction<S,? super Emitter<T>,S> generator, Consumer<? super S> disposeState, S initialState)
(package private)	SimpleBiGenerator(BiConsumer<S,Emitter<T>> consumer)
(package private)	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 final class	ObservableCreate.CreateEmitter<T>
(package private) static final class	ObservableCreate.SerializedEmitter<T>	Serializes calls to onNext, onError and onComplete.
(package private) static final 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) final BiConsumer<S,Emitter<T>>	ObservableInternalHelper.SimpleBiGenerator.consumer
(package private) final Consumer<Emitter<T>>	ObservableInternalHelper.SimpleGenerator.consumer
(package private) final BiFunction<S,Emitter<T>,S>	ObservableGenerate.generator
(package private) final 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

Modifier	Constructor	Description
(package private)	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)
(package private)	SimpleBiGenerator(BiConsumer<S,Emitter<T>> consumer)
(package private)	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).