Class ChangeStream<EventT extends BaseChangeEvent>

    • Constructor Detail

      • ChangeStream

        public ChangeStream​(Stream<EventT> stream)
        Constructs a ChangeStream from the underlying Stream.
        Parameters:
        stream - The underlying stream.
    • Method Detail

      • setExceptionListener

        public void setExceptionListener​(ExceptionListener exceptionListener)
        Optionally adds a listener that is notified when an attempt to retrieve the next event fails.
        Parameters:
        exceptionListener - The exception listener.
      • addChangeEventListener

        public void addChangeEventListener​(BaseChangeEventListener listener)
        Adds a ChangeEventListener to the ChangeStream that will run on every event on the stream. Multiple ChangeEventListeners can be added to any given stream and they will be removed when the stream is closed or when the listener is removed.
        Parameters:
        listener - the ChangeEventListener
      • removeChangeEventListener

        public void removeChangeEventListener​(BaseChangeEventListener listener)
        Remove a ChangeEventListener from the ChangeStream.
        Parameters:
        listener - the ChangeEventListener
      • isOpen

        public boolean isOpen()
        Indicates whether or not the change stream is currently open.
        Returns:
        True if the underlying change stream is open.
      • isListenerThreadRunning

        public boolean isListenerThreadRunning()
        Indicates whether or not any ChangeStreamListeners are currently running.
        Returns:
        True if the ChangeStreamListeners are running
      • removeAllChangeEventListeners

        protected void removeAllChangeEventListeners()
      • getInternalStream

        protected Stream<EventT> getInternalStream()