public interface StreamedMessageSerializer<MessageEntity> extends MessageSerializer<akka.stream.javadsl.Source<MessageEntity,?>,akka.stream.javadsl.Source<akka.util.ByteString,?>>
MessageSerializer.NegotiatedDeserializer<MessageEntity,WireFormat>, MessageSerializer.NegotiatedSerializer<MessageEntity,WireFormat>
Modifier and Type | Method and Description |
---|---|
default boolean |
isStreamed()
Whether this serializer is a streamed serializer or not.
|
acceptResponseProtocols, deserializer, isUsed, serializerForRequest, serializerForResponse
default boolean isStreamed()
MessageSerializer
isStreamed
in interface MessageSerializer<akka.stream.javadsl.Source<MessageEntity,?>,akka.stream.javadsl.Source<akka.util.ByteString,?>>