SupportSubscriber (Esper API Documentation)

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

```
public class SupportSubscriber
extends Object
```
Subscriber for that retains the events it receives for use in assertions.

Constructor Summary

Constructors
Constructor and Description

SupportSubscriber()
Ctor.

Constructors
Constructor and Description
`SupportSubscriber()` Ctor.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`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.
`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.
`Object[]`	`getAndResetLastNewData()` Returns the last array of events (insert stream) that were received and resets the subscriber.
`UniformPair<Object[]>`	`getDataListsFlattened()` Returns a pair of insert and remove stream event arrays considering the all invocations.
`Object[]`	`getLastNewData()` Returns the last array of events (insert stream) that were received.
`Object[]`	`getLastOldData()` Returns the last array of remove-stream events that were received.
`List<Object[]>`	`getNewDataList()` Get a list of all insert-stream event arrays received.
`Object[]`	`getNewDataListFlattened()` Returns an event array that represents all insert-stream events received so far.
`List<Object[]>`	`getOldDataList()` Get a list of all remove-stream event arrays received.
`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(Object[] newData, 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(Object[] newData,
                   Object[] oldData)
```
    Receive events.
    
    Parameters:
    
    newData - insert stream
    
    oldData - remove stream
  - reset
```
public void reset()
```
    Reset subscriber, clearing all associated state.
  - getLastNewData
```
public 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 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 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 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 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 List<Object[]> getNewDataList()
```
    Get a list of all insert-stream event arrays received.
    
    Returns:
    
    list of event arrays
  - getOldDataList
```
public List<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 Object[] getNewDataListFlattened()
```
    Returns an event array that represents all insert-stream events received so far.
    
    Returns:
    
    event array
  - getOldDataListFlattened
```
public Object[] getOldDataListFlattened()
```
    Returns an event array that represents all remove-stream events received so far.
    
    Returns:
    
    event array
  - getDataListsFlattened
```
public UniformPair<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

Class SupportSubscriber

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

SupportSubscriber

Method Detail

update

reset

getLastNewData

getAndResetLastNewData

assertOneGetNewAndReset

assertOneGetOldAndReset

getLastOldData

getNewDataList

getOldDataList

isInvoked

getAndClearIsInvoked

getNewDataListFlattened

getOldDataListFlattened

getDataListsFlattened