hu.akarnokd.reactive4java.reactive

Class Windowing.WithTimeOrSize<T>

java.lang.Object

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

Type Parameters:

T - the element type

All Implemented Interfaces:

Observable<Observable<T>>

Enclosing class:

Windowing

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

Projects each element into a window that is completed by either its full or the specified amount of time elapsed. Time periods are absolute from the beginning of the streaming.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
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

size

protected final int size

timespan

protected final long timespan

unit

protected final java.util.concurrent.TimeUnit unit

Constructor Detail

WithTimeOrSize

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

Constructor.

Parameters:

source - the source sequence

size - the window size

timespan - the window length

unit - the time unit

pool - the scheduler to run the timed operations

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