Package akka.http.scaladsl.unmarshalling.sse

Class EventStreamParser$

java.lang.Object
akka.http.scaladsl.unmarshalling.sse.EventStreamParser$
public class EventStreamParser$ extends 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 final EventStreamParser$
    MODULE$
    Static reference to the singleton instance of this Scala object.

  • Constructor Summary

    Constructors
    Constructor
    Description
    EventStreamParser$()
     

  • Method Summary

    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 Details

    • MODULE$

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

  • Constructor Details

    • EventStreamParser$

      public EventStreamParser$()

  • Method Details

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