我正在测试通过以下方式获得的传出流 TCP 连接传输消息的代码:
(IO(StreamTcp) ? StreamTcp.Connect(settings, address))
.mapTo[StreamTcp.OutgoingTcpConnection]
.map(_.outputStream)
在我的测试中，我将生成的 Subscriber[ByteString] 替换为虚拟订阅者，触发一些传出消息，并断言消息已按预期到达。我使用下面的方法来生成虚拟订阅者和流结果 future 。 (到目前为止，一切顺利)
def testSubscriber[T](settings: FlowMaterializer)(implicit ec: ExecutionContext): (Subscriber[T], Future[Seq[T]]) = {
var sent = Seq.empty[T]
val (subscriber, streamComplete) =
Duct[T].foreach( bs => sent = sent :+ bs)(settings)
(subscriber, streamComplete.map( _ => sent ))
}
我的问题是:是否有一些规范的方法来测试流输出预期值，类似于 Akka 的 TestActorRef？如果没有，是否有类似上述函数的库函数？
最佳答案
可以使用 akka-streams-testkit 测试流。
在这里阅读:http://doc.akka.io/docs/akka/current/scala/stream/stream-testkit.html
关于scala - 测试 Akka react 流，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/26026814/