Package rx.internal.operators
Class OnSubscribeCollect<T,R>
java.lang.Object
rx.internal.operators.OnSubscribeCollect<T,R>
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super R>>
,Function
,Observable.OnSubscribe<R>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionOnSubscribeCollect
(Observable<T> source, Func0<R> collectionFactory, Action2<R, ? super T> collector) -
Method Summary