Class BinaryMessage.Streamed

All Implemented Interfaces:
BinaryMessage, Message, Serializable, scala.Equals, scala.Product
Enclosing interface:
BinaryMessage

public static final class BinaryMessage.Streamed extends BinaryMessage implements BinaryMessage, scala.Product, Serializable
See Also:
  • Constructor Details

    • Streamed

      public Streamed(akka.stream.scaladsl.Source<akka.util.ByteString,?> dataStream)
  • Method Details

    • dataStream

      public akka.stream.scaladsl.Source<akka.util.ByteString,?> dataStream()
      Description copied from interface: BinaryMessage
      The contents of this message as a stream.
      Specified by:
      dataStream in interface BinaryMessage
      Returns:
      (undocumented)
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • getStrictData

      public akka.util.ByteString getStrictData()
      Java API
      Specified by:
      getStrictData in class BinaryMessage
      Returns:
      (undocumented)
    • isStrict

      public boolean isStrict()
      Description copied from class: Message
      Is this message a strict one?
      Specified by:
      isStrict in class Message