au.gov.amsa.util.rx

Class OperatorDynamicBuffer<T>

java.lang.Object

au.gov.amsa.util.rx.OperatorDynamicBuffer<T>

Type Parameters:

T - generic type

All Implemented Interfaces:

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

public class OperatorDynamicBuffer<T>
extends Object
implements rx.Observable.Operator<List<T>,T>

Buffers items into lists that can overlap but not more than two at a time. The commencement of the next buffer is signalled by a change in the value of startFunction and the finish of a buffer is signalled by a change in the value of the whileFunction.

Constructor Summary

Constructors

Constructor and Description
OperatorDynamicBuffer(rx.functions.Func1<T,?> startFunction, rx.functions.Func1<T,?> whileFunction) Constructor.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorDynamicBuffer

public OperatorDynamicBuffer(rx.functions.Func1<T,?> startFunction,
                             rx.functions.Func1<T,?> whileFunction)

Constructor.

Parameters:

startFunction - a change in the value of this function signals the start of a new buffer

whileFunction - a change in the value of this function signals the finish of a buffer

Method Detail

call

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

Specified by:

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