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