Interface Emitter<T>

    • Method Detail

      • send

        Emitter<T> send​(T msg)
        Deprecated.
        Sends a payload or a message to the stream.
        Parameters:
        msg - the thing to send, must not be null
        Returns:
        the current emitter
        Throws:
        IllegalStateException - if the stream does not have any pending requests, or if the stream has been cancelled or terminated.
      • complete

        void complete()
        Deprecated.
        Completes the stream. This method sends the completion signal, no messages can be sent once this method is called.
      • error

        void error​(Exception e)
        Deprecated.
        Propagates an error in the stream. This methods sends an error signal, no messages can be sent once this method is called.
        Parameters:
        e - the exception, must not be null
      • isCancelled

        boolean isCancelled()
        Deprecated.
        Returns:
        true if the emitter has been terminated or the subscription cancelled.
      • isRequested

        boolean isRequested()
        Deprecated.
        Returns:
        true if the subscriber accepts messages, false otherwise. Using send(Object) on an emitter not expecting message would throw an IllegalStateException.