hu.akarnokd.reactive4java.reactive

Class Windowing.WithTime<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Windowing.WithTime<T>

Type Parameters:

T - the source element type

All Implemented Interfaces:

Observable<Observable<T>>

Enclosing class:

Windowing

public static class Windowing.WithTime<T>
extends java.lang.Object
implements Observable<Observable<T>>

Projects elements from the source observable into zero or more windows which are produced based on timing information.

The implementation ensures that if timespan and timeshift are equal, the windows won't overlap.

Field Summary

Fields

Modifier and Type	Field and Description
protected Scheduler	pool
protected Observable<? extends T>	source
protected long	timeshift
protected long	timespan
protected java.util.concurrent.TimeUnit	unit

Constructor Summary

Constructors

Constructor and Description
WithTime(Observable<? extends T> source, long timespan, long timeshift, java.util.concurrent.TimeUnit unit, Scheduler pool) Constructor.

Method Summary

Modifier and Type	Method and Description
protected java.io.Closeable	exactWindow(Observer<? super Observable<T>> observer) Create windows by an exact timing.
protected java.io.Closeable	generalWindow(Observer<? super Observable<T>> observer) Create a general windowing operation.
java.io.Closeable	register(Observer<? super Observable<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

Field Detail

source

protected final Observable<? extends T> source

timespan

protected final long timespan

timeshift

protected final long timeshift

unit

protected final java.util.concurrent.TimeUnit unit

pool

protected final Scheduler pool

Constructor Detail

WithTime

public WithTime(Observable<? extends T> source,
                long timespan,
                long timeshift,
                java.util.concurrent.TimeUnit unit,
                Scheduler pool)

Constructor.

Parameters:

source - the source sequence

timespan - the length of each window

timeshift - the interval between the creation of consequtive windows

unit - the time unit

pool - the scheduler for the timed oeprations

Method Detail

register

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

Description copied from interface: Observable

Registers an observer for the notification of Ts.

Specified by:

register in interface Observable<Observable<T>>

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider

exactWindow

protected java.io.Closeable exactWindow(Observer<? super Observable<T>> observer)

Create windows by an exact timing.

Parameters:

observer - the observer

Returns:

the close handle

generalWindow

protected java.io.Closeable generalWindow(Observer<? super Observable<T>> observer)

Create a general windowing operation.

Parameters:

observer - the output observer

Returns:

the close handler