hu.akarnokd.reactive4java.reactive

Class AddTimeInterval<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.AddTimeInterval<T>

Type Parameters:

T - the time source

All Implemented Interfaces:

Observable<TimeInterval<T>>

public final class AddTimeInterval<T>
extends java.lang.Object
implements Observable<TimeInterval<T>>

Returns an observable which provides a TimeInterval of Ts which records the elapsed time between successive elements. The time interval is evaluated using the System.nanoTime() differences as nanoseconds. The first element contains the time elapsed since the registration occurred.

Since:

0.97

Constructor Summary

Constructors

Constructor and Description
AddTimeInterval(Observable<? extends T> source) Constructor.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	register(Observer<? super TimeInterval<T>> observer) Registers an observer for the notification of Ts.

Methods inherited from class java.lang.Object

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

Constructor Detail

AddTimeInterval

public AddTimeInterval(@Nonnull
                       Observable<? extends T> source)

Constructor.

Parameters:

source - the source sequence

Method Detail

register

@Nonnull
public java.io.Closeable register(@Nonnull
                                            Observer<? super TimeInterval<T>> observer)

Description copied from interface: Observable

Registers an observer for the notification of Ts.

Specified by:

register in interface Observable<TimeInterval<T>>

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider