public interface BinaryMessage extends Message
BinaryMessage.Strict
in which case
the complete data is already available or it can be BinaryMessage.Streamed
in which case dataStream
will return a Source streaming the data as it comes in.Modifier and Type | Interface and Description |
---|---|
static class |
BinaryMessage.Streamed |
static class |
BinaryMessage.Streamed$ |
static class |
BinaryMessage.Strict
A strict
BinaryMessage that contains the complete data as a ByteString . |
static class |
BinaryMessage.Strict$ |
Modifier and Type | Method and Description |
---|---|
BinaryMessage |
asScala() |
akka.stream.scaladsl.Source<akka.util.ByteString,?> |
dataStream()
The contents of this message as a stream.
|
akka.stream.javadsl.Source<akka.util.ByteString,?> |
getStreamedData()
Java API
|
akka.stream.scaladsl.Source<akka.util.ByteString,?> dataStream()
akka.stream.javadsl.Source<akka.util.ByteString,?> getStreamedData()
BinaryMessage asScala()