Top Inners Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeReduceSeed<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.Func2

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
OnSubscribeReduceSeed.ReduceSeedSubscriber<T, R>

Field Summary

Modifier and TypeField and Description
pack-priv final R
initialValue

pack-priv final Func2<R, ? super T, R>
reducer

pack-priv final Observable<T>
source

Constructor Summary

AccessConstructor and Description
public
OnSubscribeReduceSeed(Observable<T> source, R initialValue, Func2<R, ? super T, R> reducer)

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

initialValueback to summary
pack-priv final R initialValue
reducerback to summary
pack-priv final Func2<R, ? super T, R> reducer
sourceback to summary
pack-priv final Observable<T> source

Constructor Detail

OnSubscribeReduceSeedback to summary
public OnSubscribeReduceSeed(Observable<T> source, R initialValue, Func2<R, ? super T, R> reducer)

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 OnSubscribeReduceSeed.ReduceSeedSubscriber<T, R>

extends DeferredScalarSubscriber<T, R>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final Func2<R, ? super T, R>
reducer

Inherited from rx.internal.operators.DeferredScalarSubscriber:
actualHAS_REQUEST_HAS_VALUEHAS_REQUEST_NO_VALUEhasValueNO_REQUEST_HAS_VALUENO_REQUEST_NO_VALUEstatevalue

Constructor Summary

AccessConstructor and Description
public
ReduceSeedSubscriber(Subscriber<? super R> actual, R initialValue, Func2<R, ? super T, R> reducer)

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.DeferredScalarSubscriber:
completecompletedownstreamRequestonCompletedonErrorsetProducersetupDownstreamsubscribeTo

Field Detail

reducerback to summary
pack-priv final Func2<R, ? super T, R> reducer

Constructor Detail

ReduceSeedSubscriberback to summary
public ReduceSeedSubscriber(Subscriber<? super R> actual, R initialValue, Func2<R, ? super T, R> reducer)

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