sk.stuba.fiit.perconik.activity.listeners

Class AbstractListener.ContinuousEvent<E>

java.lang.Object

sk.stuba.fiit.perconik.activity.listeners.AbstractListener.ContinuousEvent<E>

Direct Known Subclasses:

RegularListener.ContinuousEvent

Enclosing class:

AbstractListener

protected abstract static class AbstractListener.ContinuousEvent<E>
extends java.lang.Object

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ContinuousEvent(com.google.common.base.Stopwatch watch, long pause, long window, java.util.concurrent.TimeUnit unit)

Method Summary

Modifier and Type	Method and Description
protected abstract boolean	accept(java.util.LinkedList<E> sequence, E event) Determines whether specified event is suitable for further processing.
protected abstract boolean	continuous(java.util.LinkedList<E> sequence, E event) Determines whether specified event is continuous to the event sequence.
abstract void	flush()
long	pause() Returns maximal between continuous event pause.
protected abstract void	process(java.util.LinkedList<E> sequence) Processes continuous event sequence.
abstract void	push(E event)
java.util.LinkedList<E>	sequence()
java.lang.String	toString()
protected com.google.common.base.MoreObjects.ToStringHelper	toStringHelper()
protected long	total() Returns total elapsed window time.
java.util.concurrent.TimeUnit	unit() Returns common time unit for both pause and window.
protected void	watchNotRunning() Invoked when watch not running and about to start.
protected void	watchRunningButEventsNotContinouous() Invoked when watch running but events not continuous so about to be processed.
protected void	watchTimeElapsedAndAboutToProcess(long delta) Invoked when watch time elapsed and continuous events about to be processed.
protected void	watchTimeNotElapsed(long delta) Invoked when watch time not elapsed and about to wait for next event push.
long	window() Returns maximal continuous event time window.

Methods inherited from class java.lang.Object

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

Constructor Detail

ContinuousEvent

protected ContinuousEvent(com.google.common.base.Stopwatch watch,
                          long pause,
                          long window,
                          java.util.concurrent.TimeUnit unit)

Method Detail

push

public abstract void push(E event)

flush

public abstract void flush()

sequence

public final java.util.LinkedList<E> sequence()

pause

public final long pause()

Returns maximal between continuous event pause.

window

public final long window()

Returns maximal continuous event time window.

unit

public final java.util.concurrent.TimeUnit unit()

Returns common time unit for both pause and window.

accept

protected abstract boolean accept(java.util.LinkedList<E> sequence,
                                  E event)

Determines whether specified event is suitable for further processing.

Parameters:

sequence - possibly empty continuous event sequence

event - potential event to further process

continuous

protected abstract boolean continuous(java.util.LinkedList<E> sequence,
                                      E event)

Determines whether specified event is continuous to the event sequence.

Parameters:

sequence - non-empty continuous event sequence

event - potential event sequence candidate

process

protected abstract void process(java.util.LinkedList<E> sequence)

Processes continuous event sequence.

Parameters:

sequence - non-empty continuous event sequence

total

protected final long total()

Returns total elapsed window time.

Throws:

java.lang.IllegalStateException - if watch not running

watchRunningButEventsNotContinouous

protected void watchRunningButEventsNotContinouous()

Invoked when watch running but events not continuous so about to be processed.

watchNotRunning

protected void watchNotRunning()

Invoked when watch not running and about to start.

watchTimeNotElapsed

protected void watchTimeNotElapsed(long delta)

Invoked when watch time not elapsed and about to wait for next event push.

Parameters:

delta - elapsed time delta lesser than pause

watchTimeElapsedAndAboutToProcess

protected void watchTimeElapsedAndAboutToProcess(long delta)

Invoked when watch time elapsed and continuous events about to be processed.

Parameters:

delta - elapsed time delta greater or equal to pause

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

toStringHelper

protected com.google.common.base.MoreObjects.ToStringHelper toStringHelper()