Interface BufferObserver

All Known Implementing Classes:
JoinExecStrategyDispatchable, SubselectBufferObserver

public interface BufferObserver
Observer interface to a stream publishing new and old events.
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    newData(int streamId, FlushedEventBuffer newEventBuffer, FlushedEventBuffer oldEventBuffer)
    Receive new and old events from a stream.
  • Method Details

    • newData

      void newData(int streamId, FlushedEventBuffer newEventBuffer, FlushedEventBuffer oldEventBuffer)
      Receive new and old events from a stream.
      Parameters:
      streamId - - the stream number sending the events
      newEventBuffer - - buffer for new events
      oldEventBuffer - - buffer for old events