hu.akarnokd.reactive4java.reactive

Class Windowing

java.lang.Object

hu.akarnokd.reactive4java.reactive.Windowing

public final class Windowing
extends java.lang.Object

Helper class for the Reactive.window operators.

Since:

0.97

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Windowing.WithBoundary<T,U> Projects the source elements into a non-overlapping consecutive windows.
static class	Windowing.WithClosing<T,U> Projects the parts of the source into non-overlapping observable sequences until the window observable finishes.
static class	Windowing.WithOpenClose<T,U,V> Projects the source elements into multiple, potentially overlapping windows.
static class	Windowing.WithSizeSkip<T> Project the source sequence to potentially overlapping windows whose start is determined by skip and lengths by size.
static class	Windowing.WithTime<T> Projects elements from the source observable into zero or more windows which are produced based on timing information.
static class	Windowing.WithTimeOrSize<T> Projects each element into a window that is completed by either its full or the specified amount of time elapsed.

Method Summary

Methods inherited from class java.lang.Object

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