测试Akka流不产生值

Question

我第一次使用Akka Streams Testkit，并没有找到一个很好的模式来测试一个流而不是在时间窗口内产生一个值。

这工作：

intercept[AssertionError] { // '.expectNext' throws this 
    src.request(1) 
     .expectNext(100 millis) // expect no entries in ... some time 
} 

.expectNext抛出AssertionError如果在一段时间内没有价值，但这种感觉非常错误的。我真的不想检查一个例外，我真的不想知道什么.expectNext抛出。

喜欢的东西：

src.request(1) 
    .expectNothing(100 millis) 

Answer 1

可以在docs使用

def expectNoMsg(remaining: FiniteDuration) 

使用示例。