com.lightbend.lagom.javadsl.api.deser

Interface StreamedMessageSerializer<MessageEntity>

All Superinterfaces:

MessageSerializer<akka.stream.javadsl.Source<MessageEntity,?>,akka.stream.javadsl.Source<akka.util.ByteString,?>>

public interface StreamedMessageSerializer<MessageEntity>
extends MessageSerializer<akka.stream.javadsl.Source<MessageEntity,?>,akka.stream.javadsl.Source<akka.util.ByteString,?>>

A streamed message serializer, for streams of messages.

Nested Class Summary

Nested classes/interfaces inherited from interface com.lightbend.lagom.javadsl.api.deser.MessageSerializer

MessageSerializer.NegotiatedDeserializer<MessageEntity,WireFormat>, MessageSerializer.NegotiatedSerializer<MessageEntity,WireFormat>

Method Summary

Modifier and Type	Method and Description
default boolean	isStreamed() Whether this serializer is a streamed serializer or not.

Methods inherited from interface com.lightbend.lagom.javadsl.api.deser.MessageSerializer

acceptResponseProtocols, deserializer, isUsed, serializerForRequest, serializerForResponse

Method Detail

isStreamed

default boolean isStreamed()

Description copied from interface: MessageSerializer

Whether this serializer is a streamed serializer or not.

Specified by:

isStreamed in interface MessageSerializer<akka.stream.javadsl.Source<MessageEntity,?>,akka.stream.javadsl.Source<akka.util.ByteString,?>>

Returns:

Whether this is a streamed serializer.