iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Changed test names.

Browse Source
This commit is contained in:
Dominik 2018-02-19 00:26:27 +01:00
parent 71abd78dff
commit 9ba2cebdfd
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
rxjava/src/test/java/com/baeldung/rxjava/FlowableTest.java
View File

@ -38,7 +38,7 @@ public class FlowableTest {
assertNotNull(integerFlowable); assertNotNull(integerFlowable);
} }
@Test public void whenFlowableUsesBufferStragegy_thenOnBackpressureAllValuesAreBufferedAndReceived() { @Test public void thenAllValuesAreBufferedAndReceived() {
List testList = IntStream.range(0, 100000).boxed().collect(Collectors.toList()); List testList = IntStream.range(0, 100000).boxed().collect(Collectors.toList());
Observable observable = Observable.fromIterable(testList); Observable observable = Observable.fromIterable(testList);
TestSubscriber<Integer> testSubscriber = observable.toFlowable(BackpressureStrategy.BUFFER).observeOn(Schedulers.computation()).test(); TestSubscriber<Integer> testSubscriber = observable.toFlowable(BackpressureStrategy.BUFFER).observeOn(Schedulers.computation()).test();
@ -50,7 +50,7 @@ public class FlowableTest {
assertEquals(testList, receivedInts); assertEquals(testList, receivedInts);
} }
@Test public void whenFlowableUsesDropStrategy_thenOnBackpressureNotAllValuesAreReceivedAndTheLastElementIsNotReceived() { @Test public void whenDropStrategyUsed_thenOnBackpressureDropped() {
List testList = IntStream.range(0, 100000).boxed().collect(Collectors.toList()); List testList = IntStream.range(0, 100000).boxed().collect(Collectors.toList());
Observable observable = Observable.fromIterable(testList); Observable observable = Observable.fromIterable(testList);
@ -62,7 +62,7 @@ public class FlowableTest {
assertThat(!receivedInts.contains(100000)); assertThat(!receivedInts.contains(100000));
} }
@Test public void whenFlowableUsesMissingStrategy_thenExceptionIsThrownOnBackpressure() { @Test public void whenMissingStrategyUsed_thenException() {
Observable observable = Observable.range(1, 100000); Observable observable = Observable.range(1, 100000);
TestSubscriber subscriber = observable.toFlowable(BackpressureStrategy.MISSING).observeOn(Schedulers.computation()).test(); TestSubscriber subscriber = observable.toFlowable(BackpressureStrategy.MISSING).observeOn(Schedulers.computation()).test();
@ -70,15 +70,15 @@ public class FlowableTest {
subscriber.assertError(MissingBackpressureException.class); subscriber.assertError(MissingBackpressureException.class);
} }
@Test public void whenFlowableUsesErrorStrategy_thenExceptionIsThrownOnBackpressure() { @Test public void whenErrorStrategyUsed_thenExceptionIsThrown() {
Observable observable = Observable.range(1, 100000); Observable observable = Observable.range(1, 100000);
TestSubscriber subscriber = observable.toFlowable(BackpressureStrategy.ERROR).observeOn(Schedulers.computation()).test(); TestSubscriber subscriber = observable.toFlowable(BackpressureStrategy.ERROR).observeOn(Schedulers.computation()).test();
subscriber.awaitTerminalEvent(); subscriber.awaitTerminalEvent();
subscriber.assertError(MissingBackpressureException.class); subscriber.assertError(MissingBackpressureException.class);
} }
@Test public void whenFlowableUsesLatesStrategy_thenNotElementsAreReceivedButTheLastElementIs() { @Test public void whenLatestStrategyUsed_thenTheLastElementReceived() {
List testList = IntStream.range(0, 100000).boxed().collect(Collectors.toList()); List testList = IntStream.range(0, 100000).boxed().collect(Collectors.toList());
Observable observable = Observable.fromIterable(testList); Observable observable = Observable.fromIterable(testList);
TestSubscriber<Integer> testSubscriber = observable.toFlowable(BackpressureStrategy.LATEST).observeOn(Schedulers.computation()).test(); TestSubscriber<Integer> testSubscriber = observable.toFlowable(BackpressureStrategy.LATEST).observeOn(Schedulers.computation()).test();