raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Merge pull request #20087 from akka/wip-ws-streamed-matchable-ktoso

Browse source 
+htc #20086 make ws.*Message.Streamed not private
This commit is contained in:
Konrad Malawski 2016-03-29 11:58:30 +02:00
commit 0682489a77
1 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-http-core/src/main/scala/akka/http/scaladsl/model/ws/Message.scala
View file

@ -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
}
final case class Streamed(dataStream: Source[ByteString, _]) extends BinaryMessage {
override def toString: String = s"BinaryMessage.Streamed($dataStream)"
}
}