Uses of Interface
rx.AsyncEmitter
Packages that use AsyncEmitter
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of AsyncEmitter in rx
Method parameters in rx with type arguments of type AsyncEmitterModifier and TypeMethodDescriptionstatic <T> Observable
<T> Observable.fromAsync
(Action1<AsyncEmitter<T>> asyncEmitter, AsyncEmitter.BackpressureMode backpressure) Provides an API (via a cold Observable) that bridges the reactive world with the callback-style, generally non-backpressured world. -
Uses of AsyncEmitter in rx.internal.operators
Classes in rx.internal.operators that implement AsyncEmitterModifier 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
Fields in rx.internal.operators with type parameters of type AsyncEmitterModifier and TypeFieldDescription(package private) final Action1
<AsyncEmitter<T>> OnSubscribeFromAsync.asyncEmitter
Constructor parameters in rx.internal.operators with type arguments of type AsyncEmitterModifierConstructorDescriptionOnSubscribeFromAsync
(Action1<AsyncEmitter<T>> asyncEmitter, AsyncEmitter.BackpressureMode backpressure)