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.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static EventStreamParser$ MODULE$
      Static reference to the singleton instance of this Scala object.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      akka.stream.scaladsl.Flow<akka.util.ByteString,​ServerSentEvent,​akka.NotUsed> apply​(int maxLineSize, int maxEventSize)
      Flow that converts raw byte string input into ServerSentEvents.
      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

    • Field Detail

      • MODULE$

        public static final EventStreamParser$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • EventStreamParser$

        public EventStreamParser$()

    • Method Detail

      • apply

        public 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 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)