Top Inners Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeCollect<T, R>

extends Object
implements Observable.OnSubscribe<R>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Imports
rx.*, .Observable.OnSubscribe, rx.exceptions.Exceptions, rx.functions.*

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
OnSubscribeCollect.CollectSubscriber<T, R>

Field Summary

Modifier and TypeField and Description
pack-priv final Func0<R>
collectionFactory

pack-priv final Action2<R, ? super T>
collector

pack-priv final Observable<T>
source

Constructor Summary

AccessConstructor and Description
public
OnSubscribeCollect(Observable<T> source, Func0<R> collectionFactory, Action2<R, ? super T> collector)

Method Summary

Modifier and TypeMethod and Description
public void
call(Subscriber<? super R> t)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

collectionFactoryback to summary
pack-priv final Func0<R> collectionFactory
collectorback to summary
pack-priv final Action2<R, ? super T> collector
sourceback to summary
pack-priv final Observable<T> source

Constructor Detail

OnSubscribeCollectback to summary
public OnSubscribeCollect(Observable<T> source, Func0<R> collectionFactory, Action2<R, ? super T> collector)

Method Detail

callback to summary
public void call(Subscriber<? super R> t)

Implements rx.functions.Action1.call.

Annotations
@Override
rx.internal.operators back to summary

pack-priv final Class OnSubscribeCollect.CollectSubscriber<T, R>

extends DeferredScalarSubscriberSafe<T, R>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final Action2<R, ? super T>
collector

Inherited from rx.internal.operators.DeferredScalarSubscriberSafe:
done

Constructor Summary

AccessConstructor and Description
public
CollectSubscriber(Subscriber<? super R> actual, R initialValue, Action2<R, ? super T> collector)

Method Summary

Modifier and TypeMethod and Description
public void
onNext(T
the item emitted by the Observable
t)

Implements rx.Observer.onNext.

Provides the Observer with a new item to observe.
Inherited from rx.internal.operators.DeferredScalarSubscriberSafe:
onCompletedonError

Field Detail

collectorback to summary
pack-priv final Action2<R, ? super T> collector

Constructor Detail

CollectSubscriberback to summary
public CollectSubscriber(Subscriber<? super R> actual, R initialValue, Action2<R, ? super T> collector)

Method Detail

onNextback to summary
public void onNext(T t)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters
t:T

the item emitted by the Observable

Annotations
@Override