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
|
scala.concurrent.Future<BinaryMessage.Strict> |
toStrict(scala.concurrent.duration.FiniteDuration timeout,
akka.stream.Materializer fm)
Collects all possible parts and returns a potentially future Strict Message for easier processing.
|
java.util.concurrent.CompletionStage<BinaryMessage.Strict> |
toStrict(long timeoutMillis,
akka.stream.Materializer materializer) |
akka.stream.scaladsl.Source<akka.util.ByteString,?> dataStream()
scala.concurrent.Future<BinaryMessage.Strict> toStrict(scala.concurrent.duration.FiniteDuration timeout, akka.stream.Materializer fm)
timeout
- (undocumented)fm
- (undocumented)akka.stream.javadsl.Source<akka.util.ByteString,?> getStreamedData()
BinaryMessage asScala()
java.util.concurrent.CompletionStage<BinaryMessage.Strict> toStrict(long timeoutMillis, akka.stream.Materializer materializer)