Package rx.internal.operators
Class OnSubscribeFromAsync<T>
java.lang.Object
rx.internal.operators.OnSubscribeFromAsync<T>
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super T>>
,Function
,Observable.OnSubscribe<T>
-
Nested Class Summary
Nested ClassesModifier 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 final class
(package private) static class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Action1
<AsyncEmitter<T>> (package private) final AsyncEmitter.BackpressureMode
-
Constructor Summary
ConstructorsConstructorDescriptionOnSubscribeFromAsync
(Action1<AsyncEmitter<T>> asyncEmitter, AsyncEmitter.BackpressureMode backpressure) -
Method Summary
-
Field Details
-
asyncEmitter
-
backpressure
-
-
Constructor Details
-
OnSubscribeFromAsync
public OnSubscribeFromAsync(Action1<AsyncEmitter<T>> asyncEmitter, AsyncEmitter.BackpressureMode backpressure)
-
-
Method Details