Interface TextMessage

    • Method Detail

      • textStream

        akka.stream.scaladsl.Source<java.lang.String,​?> textStream()
        The contents of this message as a stream.
        Returns:
        (undocumented)
      • toStrict

        scala.concurrent.Future<TextMessage.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. The Future is failed with an TimeoutException if the stream isn't completed after the given timeout.
        Parameters:
        timeout - (undocumented)
        fm - (undocumented)
        Returns:
        (undocumented)
      • getStreamedText

        akka.stream.javadsl.Source<java.lang.String,​?> getStreamedText()
        Java API
      • toStrict

        java.util.concurrent.CompletionStage<TextMessage.Strict> toStrict​(long timeoutMillis,
                                                                          akka.stream.Materializer materializer)