au.gov.amsa.streams

Class OperatorSubscriptionInterval<T>

java.lang.Object

au.gov.amsa.streams.OperatorSubscriptionInterval<T>

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
OperatorSubscriptionInterval(long duration, TimeUnit units, rx.Scheduler scheduler)

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

OperatorSubscriptionInterval

public OperatorSubscriptionInterval(long duration,
                                    TimeUnit units,
                                    rx.Scheduler scheduler)

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>>