hu.akarnokd.reactive4java.reactive

Class Windowing.WithOpenClose<T,U,V>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Windowing.WithOpenClose<T,U,V>

Type Parameters:

T - the source and result element type

U - the window opening element type

V - the window closing element type.

All Implemented Interfaces:

Observable<Observable<T>>

Enclosing class:

Windowing

public static class Windowing.WithOpenClose<T,U,V>
extends java.lang.Object
implements Observable<Observable<T>>

Projects the source elements into multiple, potentially overlapping windows. The window is opened by an element from the windowOpenings sequence and closed once the associated windowClosingSelector's value finishes (i.e., if it produces elements, they are ignored).

Exception semantics: exception thrown by the source or the windowClosingSelector's observable is propagated to both the outer and inner observable returned.

Field Summary

Fields

Modifier and Type	Field and Description
protected Observable<? extends T>	source
protected Func1<? super U,? extends Observable<V>>	windowClosingSelector
protected Observable<? extends U>	windowOpenings

Constructor Summary

Constructors

Constructor and Description
WithOpenClose(Observable<? extends T> source, Observable<? extends U> windowOpenings, Func1<? super U,? extends Observable<V>> windowClosingSelector) 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 Observable<? extends T> source

windowOpenings

protected Observable<? extends U> windowOpenings

windowClosingSelector

protected Func1<? super U,? extends Observable<V>> windowClosingSelector

Constructor Detail

WithOpenClose

public WithOpenClose(@Nonnull
                     Observable<? extends T> source,
                     @Nonnull
                     Observable<? extends U> windowOpenings,
                     @Nonnull
                     Func1<? super U,? extends Observable<V>> windowClosingSelector)

Constructor.

Parameters:

source - the source sequence

windowOpenings - the sequence producing the window-open events

windowClosingSelector - the selector producing a window-closing sequence for the pair window-open event.

Method Detail

register

@Nonnull
public java.io.Closeable register(@Nonnull
                                            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