hu.akarnokd.reactive4java.reactive

Class Skip.LastTimed<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Skip.LastTimed<T>

Type Parameters:

T - the element type

All Implemented Interfaces:

Observable<T>

Enclosing class:

Skip

public static class Skip.LastTimed<T>
extends java.lang.Object
implements Observable<T>

Skips the elements from the end for the specified amount of time.

Since there is no way to know the total duration of the sequence, the operator queues elements unit they become older than the specified time, causing the elements to be delayed by time.

Constructor Summary

Constructors

Constructor and Description
LastTimed(Observable<? extends T> source, long time, java.util.concurrent.TimeUnit unit) Constructor.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	register(Observer<? super 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

LastTimed

public LastTimed(Observable<? extends T> source,
                 long time,
                 java.util.concurrent.TimeUnit unit)

Constructor.

Parameters:

source - the source sequence

time - the time to skip from last

unit - the time unit

Method Detail

register

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

Description copied from interface: Observable

Registers an observer for the notification of Ts.

Specified by:

register in interface Observable<T>

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider