diff --git a/akka-http-core/src/main/scala/akka/http/scaladsl/model/ws/Message.scala b/akka-http-core/src/main/scala/akka/http/scaladsl/model/ws/Message.scala index 0aa8362f24..59ed41f773 100644 --- a/akka-http-core/src/main/scala/akka/http/scaladsl/model/ws/Message.scala +++ b/akka-http-core/src/main/scala/akka/http/scaladsl/model/ws/Message.scala @@ -37,7 +37,9 @@ object TextMessage { def textStream: Source[String, _] = Source.single(text) override def toString: String = s"TextMessage.Strict($text)" } - final private case class Streamed(textStream: Source[String, _]) extends TextMessage + final case class Streamed(textStream: Source[String, _]) extends TextMessage { + override def toString: String = s"TextMessage.Streamed($textStream)" + } } /** @@ -65,5 +67,7 @@ object BinaryMessage { def dataStream: Source[ByteString, _] = Source.single(data) override def toString: String = s"BinaryMessage.Strict($data)" } - final private case class Streamed(dataStream: Source[ByteString, _]) extends BinaryMessage -} \ No newline at end of file + final case class Streamed(dataStream: Source[ByteString, _]) extends BinaryMessage { + override def toString: String = s"BinaryMessage.Streamed($dataStream)" + } +}