Uses of Interface
io.reactivex.rxjava3.core.Emitter
Packages that use Emitter
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.-
Uses of Emitter in io.reactivex.rxjava3.core
Subinterfaces of Emitter in io.reactivex.rxjava3.coreModifier and TypeInterfaceDescriptioninterface
Abstraction over a Reactive StreamsSubscriber
that allows associating a resource with it and exposes the current number of downstream requested amount.interface
Abstraction over an RxJavaObserver
that allows associating a resource with it.Method parameters in io.reactivex.rxjava3.core with type arguments of type EmitterModifier and TypeMethodDescriptionReturns a cold, synchronous, stateless and backpressure-aware generator of values.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.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.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.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> 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 EmitterModifier and TypeClassDescription(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
Serializes calls to onNext, onError and onComplete.(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type EmitterModifier and TypeFieldDescription(package private) final BiConsumer
<S, Emitter<T>> FlowableInternalHelper.SimpleBiGenerator.consumer
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 EmitterModifier and TypeMethodDescriptionstatic <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 EmitterModifier and TypeMethodDescriptionMethod parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type EmitterModifier and TypeMethodDescriptionstatic <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 EmitterModifierConstructorDescriptionFlowableGenerate
(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 EmitterModifier and TypeClassDescription(package private) static final class
(package private) static final class
Serializes calls to onNext, onError and onComplete.(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type EmitterModifier and TypeFieldDescription(package private) final BiConsumer
<S, Emitter<T>> ObservableInternalHelper.SimpleBiGenerator.consumer
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 EmitterModifier and TypeMethodDescriptionstatic <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 EmitterModifier and TypeMethodDescriptionMethod parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type EmitterModifier and TypeMethodDescriptionstatic <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 EmitterModifierConstructorDescription(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 EmitterModifier and TypeMethodDescriptionvoid
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).