public final class OnSubscribeCollect<T,R> extends Object implements Observable.OnSubscribe<R>
Constructor and Description |
---|
OnSubscribeCollect(Observable<T> source,
Func0<R> collectionFactory,
Action2<R,? super T> collector) |
public void call(Subscriber<? super R> t)
call
in interface Action1<Subscriber<? super R>>
Copyright © 2018. All rights reserved.