From 9ba2cebdfd294a25567d27d54ee00aaaabab68c1 Mon Sep 17 00:00:00 2001 From: Dominik Date: Mon, 19 Feb 2018 00:26:27 +0100 Subject: [PATCH] Changed test names. --- .../test/java/com/baeldung/rxjava/FlowableTest.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/rxjava/src/test/java/com/baeldung/rxjava/FlowableTest.java b/rxjava/src/test/java/com/baeldung/rxjava/FlowableTest.java index 26b17ec163..b9d1d64c24 100644 --- a/rxjava/src/test/java/com/baeldung/rxjava/FlowableTest.java +++ b/rxjava/src/test/java/com/baeldung/rxjava/FlowableTest.java @@ -38,7 +38,7 @@ public class FlowableTest { assertNotNull(integerFlowable); } - @Test public void whenFlowableUsesBufferStragegy_thenOnBackpressureAllValuesAreBufferedAndReceived() { + @Test public void thenAllValuesAreBufferedAndReceived() { List testList = IntStream.range(0, 100000).boxed().collect(Collectors.toList()); Observable observable = Observable.fromIterable(testList); TestSubscriber testSubscriber = observable.toFlowable(BackpressureStrategy.BUFFER).observeOn(Schedulers.computation()).test(); @@ -50,7 +50,7 @@ public class FlowableTest { assertEquals(testList, receivedInts); } - @Test public void whenFlowableUsesDropStrategy_thenOnBackpressureNotAllValuesAreReceivedAndTheLastElementIsNotReceived() { + @Test public void whenDropStrategyUsed_thenOnBackpressureDropped() { List testList = IntStream.range(0, 100000).boxed().collect(Collectors.toList()); Observable observable = Observable.fromIterable(testList); @@ -62,7 +62,7 @@ public class FlowableTest { assertThat(!receivedInts.contains(100000)); } - @Test public void whenFlowableUsesMissingStrategy_thenExceptionIsThrownOnBackpressure() { + @Test public void whenMissingStrategyUsed_thenException() { Observable observable = Observable.range(1, 100000); TestSubscriber subscriber = observable.toFlowable(BackpressureStrategy.MISSING).observeOn(Schedulers.computation()).test(); @@ -70,15 +70,15 @@ public class FlowableTest { subscriber.assertError(MissingBackpressureException.class); } - @Test public void whenFlowableUsesErrorStrategy_thenExceptionIsThrownOnBackpressure() { - Observable observable = Observable.range(1, 100000); + @Test public void whenErrorStrategyUsed_thenExceptionIsThrown() { + Observable observable = Observable.range(1, 100000); TestSubscriber subscriber = observable.toFlowable(BackpressureStrategy.ERROR).observeOn(Schedulers.computation()).test(); subscriber.awaitTerminalEvent(); subscriber.assertError(MissingBackpressureException.class); } - @Test public void whenFlowableUsesLatesStrategy_thenNotElementsAreReceivedButTheLastElementIs() { + @Test public void whenLatestStrategyUsed_thenTheLastElementReceived() { List testList = IntStream.range(0, 100000).boxed().collect(Collectors.toList()); Observable observable = Observable.fromIterable(testList); TestSubscriber testSubscriber = observable.toFlowable(BackpressureStrategy.LATEST).observeOn(Schedulers.computation()).test();