Interface StreamEventPublisher<StreamEventType extends EventStreamJsonMessage>

    • Method Detail

      • sendStreamEvent

        CompletableFuture<Void> sendStreamEvent​(StreamEventType streamEvent)
        Publish an event over an open stream operation.
        Parameters:
        streamEvent - event to publish
        Returns:
        Completable future indicating flush of the event over the stream
      • closeStream

        CompletableFuture<Void> closeStream()
        Closes the stream by sending an empty message
        Returns:
        Completable future indicating flush of the stream termination message