測試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) 

使用示例。