com.espertech.esper.client.scopetest
Class SupportSubscriber

java.lang.Object
  com.espertech.esper.client.scopetest.SupportSubscriber

public class SupportSubscriber
extends java.lang.Object

Subscriber for that retains the events it receives for use in assertions.

Constructor Summary

SupportSubscriber()
Ctor.

Method Summary

java.lang.Object	assertOneGetNewAndReset() Asserts that exactly one insert stream event was received and no remove stream events, resets the listener clearing all state and returns the received event.
java.lang.Object	assertOneGetOldAndReset() Asserts that exactly one remove stream event was received and no insert stream events, resets the listener clearing all state and returns the received event.
boolean	getAndClearIsInvoked() Returns true if the subscriber was invoked at least once and clears the invocation flag.
java.lang.Object[]	getAndResetLastNewData() Returns the last array of events (insert stream) that were received and resets the subscriber.
UniformPair<java.lang.Object[]>	getDataListsFlattened() Returns a pair of insert and remove stream event arrays considering the all invocations.
java.lang.Object[]	getLastNewData() Returns the last array of events (insert stream) that were received.
java.lang.Object[]	getLastOldData() Returns the last array of remove-stream events that were received.
java.util.List<java.lang.Object[]>	getNewDataList() Get a list of all insert-stream event arrays received.
java.lang.Object[]	getNewDataListFlattened() Returns an event array that represents all insert-stream events received so far.
java.util.List<java.lang.Object[]>	getOldDataList() Get a list of all remove-stream event arrays received.
java.lang.Object[]	getOldDataListFlattened() Returns an event array that represents all remove-stream events received so far.
boolean	isInvoked() Returns true if the subscriber was invoked at least once.
void	reset() Reset subscriber, clearing all associated state.
void	update(java.lang.Object[] newData, java.lang.Object[] oldData) Receive events.

Methods inherited from class java.lang.Object

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

Constructor Detail

SupportSubscriber

public SupportSubscriber()

Ctor.

Method Detail

update

public void update(java.lang.Object[] newData,
                   java.lang.Object[] oldData)

Receive events.

Parameters:

newData - insert stream

oldData - remove stream

reset

public void reset()

Reset subscriber, clearing all associated state.

getLastNewData

public java.lang.Object[] getLastNewData()

Returns the last array of events (insert stream) that were received.

Returns:

insert stream events or null if either a null value was received or when no events have been received since the last reset

getAndResetLastNewData

public java.lang.Object[] getAndResetLastNewData()

Returns the last array of events (insert stream) that were received and resets the subscriber.

Returns:

insert stream events or null if either a null value was received or when no events have been received since the last reset

assertOneGetNewAndReset

public java.lang.Object assertOneGetNewAndReset()

Asserts that exactly one insert stream event was received and no remove stream events, resets the listener clearing all state and returns the received event.

Returns:

single insert-stream event

assertOneGetOldAndReset

public java.lang.Object assertOneGetOldAndReset()

Asserts that exactly one remove stream event was received and no insert stream events, resets the listener clearing all state and returns the received event.

Returns:

single remove-stream event

getLastOldData

public java.lang.Object[] getLastOldData()

Returns the last array of remove-stream events that were received.

Returns:

remove stream events or null if either a null value was received or when no events have been received since the last reset

getNewDataList

public java.util.List<java.lang.Object[]> getNewDataList()

Get a list of all insert-stream event arrays received.

Returns:

list of event arrays

getOldDataList

public java.util.List<java.lang.Object[]> getOldDataList()

Get a list of all remove-stream event arrays received.

Returns:

list of event arrays

isInvoked

public boolean isInvoked()

Returns true if the subscriber was invoked at least once.

Returns:

invoked flag

getAndClearIsInvoked

public boolean getAndClearIsInvoked()

Returns true if the subscriber was invoked at least once and clears the invocation flag.

Returns:

invoked flag

getNewDataListFlattened

public java.lang.Object[] getNewDataListFlattened()

Returns an event array that represents all insert-stream events received so far.

Returns:

event array

getOldDataListFlattened

public java.lang.Object[] getOldDataListFlattened()

Returns an event array that represents all remove-stream events received so far.

Returns:

event array

getDataListsFlattened

public UniformPair<java.lang.Object[]> getDataListsFlattened()

Returns a pair of insert and remove stream event arrays considering the all invocations.

Returns:

pair of event arrays, the first in the pair is the insert stream data, the second in the pair is the remove stream data