reactor.core.action

Class WindowAction<T>

java.lang.Object

reactor.core.action.Action<T>

reactor.core.action.WindowAction<T>

All Implemented Interfaces:

Flushable<T>, Pausable, Consumer<Event<T>>

Direct Known Subclasses:

MovingWindowAction

public class WindowAction<T>
extends Action<T>
implements Pausable, Flushable<T>

WindowAction is collecting events on a steam until is reached, after that streams collected events further, clears the internal collection and starts collecting items from empty list.

Field Summary

Fields inherited from interface reactor.core.action.Flushable

FLUSH_EVENT

Constructor Summary

Constructors

Constructor and Description
WindowAction(Observable d, java.lang.Object successKey, java.lang.Object failureKey, Timer timer, int period, java.util.concurrent.TimeUnit timeUnit, int delay)

Method Summary

Modifier and Type	Method and Description
Pausable	cancel() Cancel this Pausable.
void	doAccept(Event<T> value)
protected void	doWindow(java.lang.Long aLong)
Flushable<T>	flush() Trigger flush on this component, generally draining any collected values.
Pausable	pause() Pause this Pausable.
Pausable	resume() Unpause this Pausable.

Methods inherited from class reactor.core.action.Action

accept, getFailureKey, getObservable, getSuccessKey, notifyError, notifyValue, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

WindowAction

public WindowAction(Observable d,
                    java.lang.Object successKey,
                    java.lang.Object failureKey,
                    Timer timer,
                    int period,
                    java.util.concurrent.TimeUnit timeUnit,
                    int delay)

Method Detail

doWindow

protected void doWindow(java.lang.Long aLong)

doAccept

public void doAccept(Event<T> value)

Specified by:

doAccept in class Action<T>

cancel

public Pausable cancel()

Description copied from interface: Pausable

Cancel this Pausable. The implementing component should never react to any stimulus, closing resources if necessary.

Specified by:

cancel in interface Pausable

Returns:

this

pause

public Pausable pause()

Description copied from interface: Pausable

Pause this Pausable. The implementing component should stop reacting, pausing resources if necessary.

Specified by:

pause in interface Pausable

Returns:

this

resume

public Pausable resume()

Description copied from interface: Pausable

Unpause this Pausable. The implementing component should resume back from a previous pause, re-activating resources if necessary.

Specified by:

resume in interface Pausable

Returns:

this

flush

public Flushable<T> flush()

Description copied from interface: Flushable

Trigger flush on this component, generally draining any collected values.

Specified by:

flush in interface Flushable<T>