public static final class BinaryMessage.Streamed extends BinaryMessage implements BinaryMessage, scala.Product, java.io.Serializable
BinaryMessage.Streamed, BinaryMessage.Streamed$, BinaryMessage.Strict, BinaryMessage.Strict$
Constructor and Description |
---|
Streamed(org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,?> dataStream) |
Modifier and Type | Method and Description |
---|---|
org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,?> |
dataStream()
The contents of this message as a stream.
|
org.apache.pekko.util.ByteString |
getStrictData()
Java API
|
boolean |
isStrict()
Is this message a strict one?
|
java.lang.String |
toString() |
adapt, asBinaryMessage, asScala, asTextMessage, create, create, getStreamedData, isText, toStrict
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
asScala, getStreamedData, toStrict, toStrict
public Streamed(org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,?> dataStream)
public org.apache.pekko.stream.scaladsl.Source<org.apache.pekko.util.ByteString,?> dataStream()
BinaryMessage
dataStream
in interface BinaryMessage
public java.lang.String toString()
toString
in class java.lang.Object
public org.apache.pekko.util.ByteString getStrictData()
getStrictData
in class BinaryMessage