Click or drag to resize

SupportSubscriber Class

EPSubscriber for that retains the events it receives for use in assertions.
Inheritance Hierarchy
SystemObject
  com.espertech.esper.runtime.client.scopetestSupportSubscriber

Namespace:  com.espertech.esper.runtime.client.scopetest
Assembly:  NEsper.Runtime (in NEsper.Runtime.dll) Version: 8.0.0.0
Syntax
C#
public class SupportSubscriber

The SupportSubscriber type exposes the following members.

Constructors
  NameDescription
Public methodSupportSubscriber
Ctor.
Top
Properties
  NameDescription
Public propertyDataListsFlattened
Returns a pair of insert and remove stream event arrays considering the all invocations.
Public propertyIsInvoked
Returns true if the subscriber was invoked at least once.
Public propertyLastNewData
Returns the last array of events (insert stream) that were received.
Public propertyLastOldData
Returns the last array of remove-stream events that were received.
Public propertyNewDataList
Get a list of all insert-stream event arrays received.
Public propertyNewDataListFlattened
Returns an event array that represents all insert-stream events received so far.
Public propertyOldDataList
Get a list of all remove-stream event arrays received.
Public propertyOldDataListFlattened
Returns an event array that represents all remove-stream events received so far.
Top
Methods
  NameDescription
Public methodAssertOneGetNewAndReset
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.
Public methodAssertOneGetOldAndReset
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.
Public methodGetAndClearIsInvoked
Returns true if the subscriber was invoked at least once and clears the invocation flag.
Public methodGetAndResetLastNewData
Returns the last array of events (insert stream) that were received and resets the subscriber.
Public methodReset
Reset subscriber, clearing all associated state.
Public methodUpdate
Receive events.
Top
See Also