Package akka.http.scaladsl.unmarshalling.sse

Class EventStreamParser

  • public class EventStreamParser
extends java.lang.Object
    Flow that converts raw byte string input into ServerSentEvents.

    This API is made for use in non-akka-http clients, like Play's WSClient.

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static akka.stream.scaladsl.Flow<akka.util.ByteString,​ServerSentEvent,​akka.NotUsed> apply​(int maxLineSize, int maxEventSize)
      Flow that converts raw byte string input into ServerSentEvents.
      static akka.stream.scaladsl.Flow<akka.util.ByteString,​ServerSentEvent,​akka.NotUsed> apply​(int maxLineSize, int maxEventSize, boolean emitEmptyEvents)
      Flow that converts raw byte string input into ServerSentEvents.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • EventStreamParser

        public EventStreamParser()

    • Method Detail

      • apply

        public static akka.stream.scaladsl.Flow<akka.util.ByteString,​ServerSentEvent,​akka.NotUsed> apply​(int maxLineSize,
                                                                                                             int maxEventSize)
        Flow that converts raw byte string input into ServerSentEvents.

        This API is made for use in non-akka-http clients, like Play's WSClient.

        Parameters:
        maxLineSize - The maximum size of a line for the event Stream parser
        maxEventSize - The maximum size of a server-sent event for the event Stream parser
        Returns:
        (undocumented)

      • apply

        public static akka.stream.scaladsl.Flow<akka.util.ByteString,​ServerSentEvent,​akka.NotUsed> apply​(int maxLineSize,
                                                                                                             int maxEventSize,
                                                                                                             boolean emitEmptyEvents)
        Flow that converts raw byte string input into ServerSentEvents.

        This API is made for use in non-akka-http clients, like Play's WSClient.

        Parameters:
        maxLineSize - The maximum size of a line for the event Stream parser
        maxEventSize - The maximum size of a server-sent event for the event Stream parser
        emitEmptyEvents - Should the parser emit events with empty data field
        Returns:
        (undocumented)