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

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)

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)

Uses of Emitter in io.reactivex.rxjava3.internal.operators.observable

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)

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
	ObservableGenerate(Supplier<S> stateSupplier, BiFunction<S, Emitter<T>, S> generator, Consumer<? super S> disposeState)

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).