reactor.core.action

Class MovingWindowAction<T>

java.lang.Object

reactor.core.action.Action<T>

reactor.core.action.WindowAction<T>

reactor.core.action.MovingWindowAction<T>

All Implemented Interfaces:

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

public class MovingWindowAction<T>
extends WindowAction<T>

MovingWindowAction is collecting maximum events on a stream until is reached, after that steams collected events further, and continues collecting without clearing the list.

Field Summary

Fields inherited from interface reactor.core.action.Flushable

FLUSH_EVENT

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	doAccept(Event<T> value)
protected void	doWindow(java.lang.Long aLong)

Methods inherited from class reactor.core.action.WindowAction

cancel, flush, pause, resume

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

MovingWindowAction

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

Method Detail

doWindow

protected void doWindow(java.lang.Long aLong)

Overrides:

doWindow in class WindowAction<T>

doAccept

public void doAccept(Event<T> value)

Overrides:

doAccept in class WindowAction<T>