Uses of Interface
rx.AsyncEmitter

Packages that use AsyncEmitter

Package	Description
rx	Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.
rx.internal.operators	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 AsyncEmitter

Modifier and Type	Method	Description
static <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 AsyncEmitter

Modifier and Type	Class	Description
(package private) static class	OnSubscribeFromAsync.BaseAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.BufferAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.DropAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.ErrorAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.LatestAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.NoneAsyncEmitter<T>
(package private) static class	OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter<T>

Fields in rx.internal.operators with type parameters of type AsyncEmitter

Modifier and Type	Field	Description
(package private) Action1<AsyncEmitter<T>>	OnSubscribeFromAsync.asyncEmitter

Constructor parameters in rx.internal.operators with type arguments of type AsyncEmitter

Constructor	Description
OnSubscribeFromAsync(Action1<AsyncEmitter<T>> asyncEmitter, AsyncEmitter.BackpressureMode backpressure)