org.apache.pekko.http.scaladsl.unmarshalling.sse

Class EventStreamUnmarshalling$

java.lang.Object

org.apache.pekko.http.scaladsl.unmarshalling.sse.EventStreamUnmarshalling$

All Implemented Interfaces:

EventStreamUnmarshalling

public class EventStreamUnmarshalling$
extends java.lang.Object
implements EventStreamUnmarshalling

Importing EventStreamUnmarshalling.fromEventsStream lets an HttpEntity with a text/event-stream media type be unmarshalled to a source of ServerSentEvents.

The maximum size for parsing server-sent events is 8KiB. The maximum size for parsing lines of a server-sent event is 4KiB. If you need to customize any of these, set the pekko.http.sse.max-event-size and pekko.http.sse.max-line-size properties respectively.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
EventStreamUnmarshalling$()

Method Summary

Modifier and Type	Method and Description
Unmarshaller<HttpEntity,org.apache.pekko.stream.scaladsl.Source<ServerSentEvent,org.apache.pekko.NotUsed>>	fromEventStream() Deprecated. Binary compatibility method. Invocations should have an implicit ActorSystem in scope to provide access to configuration. Since Akka HTTP 10.1.8.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pekko.http.scaladsl.unmarshalling.sse.EventStreamUnmarshalling

fromEventsStream, fromEventsStream, fromEventsStream, maxEventSize, maxLineSize

Field Detail

MODULE$

public static final EventStreamUnmarshalling$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

EventStreamUnmarshalling$

public EventStreamUnmarshalling$()

Method Detail

fromEventStream

public final Unmarshaller<HttpEntity,org.apache.pekko.stream.scaladsl.Source<ServerSentEvent,org.apache.pekko.NotUsed>> fromEventStream()

Deprecated. Binary compatibility method. Invocations should have an implicit ActorSystem in scope to provide access to configuration. Since Akka HTTP 10.1.8.

Specified by:

fromEventStream in interface EventStreamUnmarshalling