com.github.davidmoten.rx.internal.operators

Class OperatorBufferEmissions<T>

java.lang.Object

com.github.davidmoten.rx.internal.operators.OperatorBufferEmissions<T>

All Implemented Interfaces:

rx.functions.Func1<rx.Subscriber<? super T>,rx.Subscriber<? super T>>, rx.functions.Function, rx.Observable.Operator<T,T>

public final class OperatorBufferEmissions<T>
extends Object
implements rx.Observable.Operator<T,T>

Constructor Summary

Constructors

Constructor and Description
OperatorBufferEmissions() Internal API.

Method Summary

Modifier and Type	Method and Description
rx.Subscriber<? super T>	call(rx.Subscriber<? super T> child)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OperatorBufferEmissions

public OperatorBufferEmissions()

Internal API. Use Transformers.bufferEmissions() instead.

Method Detail

call

public rx.Subscriber<? super T> call(rx.Subscriber<? super T> child)

Specified by:

call in interface rx.functions.Func1<rx.Subscriber<? super T>,rx.Subscriber<? super T>>