public class SupportSubscriber
extends java.lang.Object
Constructor and Description |
---|
SupportSubscriber()
Ctor.
|
Modifier and Type | Method and Description |
---|---|
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.
|
public void update(java.lang.Object[] newData, java.lang.Object[] oldData)
newData
- insert streamoldData
- remove streampublic void reset()
public java.lang.Object[] getLastNewData()
public java.lang.Object[] getAndResetLastNewData()
public java.lang.Object assertOneGetNewAndReset()
public java.lang.Object assertOneGetOldAndReset()
public java.lang.Object[] getLastOldData()
public java.util.List<java.lang.Object[]> getNewDataList()
public java.util.List<java.lang.Object[]> getOldDataList()
public boolean isInvoked()
public boolean getAndClearIsInvoked()
public java.lang.Object[] getNewDataListFlattened()
public java.lang.Object[] getOldDataListFlattened()
public UniformPair<java.lang.Object[]> getDataListsFlattened()