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

chore: Fix RecipeAdhocSource test.

Browse source
This commit is contained in:
He-Pin 2023-12-28 17:07:27 +08:00 • committed by kerr
parent 09023ce47a
commit d829637ef2
2 changed files with 9 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

3
docs/src/test/java/jdocs/stream/javadsl/cookbook/RecipeAdhocSourceTest.java
View file

@ -18,6 +18,7 @@ import org.apache.pekko.NotUsed;
import org.apache.pekko.actor.ActorSystem;
import org.apache.pekko.dispatch.Futures;
import org.apache.pekko.japi.pf.PFBuilder;
import org.apache.pekko.stream.BackpressureTimeoutException;
import org.apache.pekko.stream.javadsl.Keep;
import org.apache.pekko.stream.javadsl.Source;
import org.apache.pekko.stream.testkit.TestSubscriber;
@ -232,7 +233,7 @@ public class RecipeAdhocSourceTest extends RecipeTest {
assertEquals(4, startedCount.get()); // startCount == 4, which means "re"-tried 3 times
Thread.sleep(500);
assertEquals(TimeoutException.class, probe.expectError().getClass());
assertEquals(BackpressureTimeoutException.class, probe.expectError().getClass());
probe.request(1); // send demand
probe.expectNoMessage(FiniteDuration.create(200, "milliseconds")); // but no more restart
}