2
내가 통해 얻은 나가는 스트림 TCP 연결을 통해 메시지 스트림 코드를 테스트 해요 : 나는 더미 가입자와 결과 Subscriber[ByteString] 대체 어떤 보내는 메시지를 트리거, 내 테스트에서테스트 Akka 반응성 스트림
(IO(StreamTcp) ? StreamTcp.Connect(settings, address))
.mapTo[StreamTcp.OutgoingTcpConnection]
.map(_.outputStream)
을, 예상대로 도착했다고 주장합니다. 나는 더미 가입자와 스트림 결과 미래를 생산하기 위해 아래의 방법을 사용한다. , Akka의 TestActorRef에 비슷한 출력이 예상 값을 스트림 테스트를위한 표준적인 방법이있다 : (지금까지 너무 좋아)
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))
}
내 질문은 이것이다? 그리고 그렇지 않다면 위의 함수와 비슷한 라이브러리 함수가 있습니까?