public class EventStreamUnmarshalling$
extends java.lang.Object
fromEventsStream
lets a HttpEntity
with a text/event-stream
media type be unmarshalled to a source of
ServerSentEvent
s.Modifier and Type | Field and Description |
---|---|
static EventStreamUnmarshalling$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
EventStreamUnmarshalling$() |
Modifier and Type | Method and Description |
---|---|
Unmarshaller<HttpEntity,org.apache.pekko.stream.javadsl.Source<ServerSentEvent,org.apache.pekko.NotUsed>> |
fromEventsStream(org.apache.pekko.actor.ActorSystem system)
Lets an
HttpEntity with a text/event-stream media type be unmarshalled to a source of ServerSentEvent s. |
Unmarshaller<HttpEntity,org.apache.pekko.stream.javadsl.Source<ServerSentEvent,org.apache.pekko.NotUsed>> |
fromEventsStream(ServerSentEventSettings settings)
Lets an
HttpEntity with a text/event-stream media type be unmarshalled to a source of ServerSentEvent s. |
Unmarshaller<HttpEntity,org.apache.pekko.stream.javadsl.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.
|
public static final EventStreamUnmarshalling$ MODULE$
public Unmarshaller<HttpEntity,org.apache.pekko.stream.javadsl.Source<ServerSentEvent,org.apache.pekko.NotUsed>> fromEventsStream(org.apache.pekko.actor.ActorSystem system)
HttpEntity
with a text/event-stream
media type be unmarshalled to a source of ServerSentEvent
s.system
- (undocumented)public Unmarshaller<HttpEntity,org.apache.pekko.stream.javadsl.Source<ServerSentEvent,org.apache.pekko.NotUsed>> fromEventsStream(ServerSentEventSettings settings)
HttpEntity
with a text/event-stream
media type be unmarshalled to a source of ServerSentEvent
s.settings
- overrides the default unmarshalling behavior.public Unmarshaller<HttpEntity,org.apache.pekko.stream.javadsl.Source<ServerSentEvent,org.apache.pekko.NotUsed>> fromEventStream()