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

RxJava refactor (#2754)

Browse Source 
* RxJava refactor

* RxJava refactor
This commit is contained in:
Grzegorz Piwowarek 2017-10-19 12:50:18 +02:00 committed by GitHub
parent 1a4812d722
commit 325ba1f147
1 changed files with 25 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
rxjava/src/test/java/com/baeldung/rxjava/operators/RxAggregateOperatorsTest.java
View File

@ -4,7 +4,12 @@ import org.junit.Test;
import rx.Observable; import rx.Observable;
import rx.observers.TestSubscriber; import rx.observers.TestSubscriber;
import java.util.*; import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
public class RxAggregateOperatorsTest { public class RxAggregateOperatorsTest {
@ -29,7 +34,6 @@ public class RxAggregateOperatorsTest {
subscriber.assertNoErrors(); subscriber.assertNoErrors();
subscriber.assertValueCount(8); subscriber.assertValueCount(8);
subscriber.assertValues(1, 2, 3, 4, 5, 6, 7, 8); subscriber.assertValues(1, 2, 3, 4, 5, 6, 7, 8);
} }
@Test @Test
@ -41,7 +45,7 @@ public class RxAggregateOperatorsTest {
// when // when
Observable<Integer> sourceObservable = Observable.from(lettersList) Observable<Integer> sourceObservable = Observable.from(lettersList)
.count(); .count();
sourceObservable.subscribe(subscriber); sourceObservable.subscribe(subscriber);
// then // then
@ -60,7 +64,7 @@ public class RxAggregateOperatorsTest {
// when // when
Observable<String> reduceObservable = Observable.from(list) Observable<String> reduceObservable = Observable.from(list)
.reduce((letter1, letter2) -> letter2 + letter1); .reduce((letter1, letter2) -> letter2 + letter1);
reduceObservable.subscribe(subscriber); reduceObservable.subscribe(subscriber);
// then // then
@ -78,15 +82,15 @@ public class RxAggregateOperatorsTest {
TestSubscriber<HashSet> subscriber = TestSubscriber.create(); TestSubscriber<HashSet> subscriber = TestSubscriber.create();
// when // when
Observable<HashSet> reduceListObservable = Observable.from(list) Observable<HashSet<String>> reduceListObservable = Observable.from(list)
.collect(() -> new HashSet(), (set, item) -> set.add(item)); .collect(HashSet::new, HashSet::add);
reduceListObservable.subscribe(subscriber); reduceListObservable.subscribe(subscriber);
// then // then
subscriber.assertCompleted(); subscriber.assertCompleted();
subscriber.assertNoErrors(); subscriber.assertNoErrors();
subscriber.assertValueCount(1); subscriber.assertValueCount(1);
subscriber.assertValues(new HashSet(list)); subscriber.assertValues(new HashSet<>(list));
} }
@Test @Test
@ -104,7 +108,6 @@ public class RxAggregateOperatorsTest {
subscriber.assertNoErrors(); subscriber.assertNoErrors();
subscriber.assertValueCount(1); subscriber.assertValueCount(1);
subscriber.assertValue(Arrays.asList(1, 2, 3, 4, 5)); subscriber.assertValue(Arrays.asList(1, 2, 3, 4, 5));
} }
@Test @Test
@ -139,17 +142,21 @@ public class RxAggregateOperatorsTest {
subscriber.assertNoErrors(); subscriber.assertNoErrors();
subscriber.assertValueCount(1); subscriber.assertValueCount(1);
subscriber.assertValue(Arrays.asList(14, 13, 12, 11, 10)); subscriber.assertValue(Arrays.asList(14, 13, 12, 11, 10));
} }
@Test @Test
public void givenObservable_whenUsingToMap_thenObtainedAMap() { public void givenObservable_whenUsingToMap_thenObtainedAMap() {
// given // given
Observable<Book> bookObservable = Observable.just(new Book("The North Water", 2016), new Book("Origin", 2017), new Book("Sleeping Beauties", 2017)); Observable<Book> bookObservable = Observable
.just(
new Book("The North Water", 2016),
new Book("Origin", 2017),
new Book("Sleeping Beauties", 2017));
TestSubscriber<Map> subscriber = TestSubscriber.create(); TestSubscriber<Map> subscriber = TestSubscriber.create();
// when // when
Observable<Map<String, Integer>> mapObservable = bookObservable.toMap(Book::getTitle, Book::getYear, HashMap::new); Observable<Map<String, Integer>> mapObservable = bookObservable
.toMap(Book::getTitle, Book::getYear, HashMap::new);
mapObservable.subscribe(subscriber); mapObservable.subscribe(subscriber);
@ -169,11 +176,16 @@ public class RxAggregateOperatorsTest {
@Test @Test
public void givenObservable_whenUsingToMultiMap_thenObtainedAMultiMap() { public void givenObservable_whenUsingToMultiMap_thenObtainedAMultiMap() {
// given // given
Observable<Book> bookObservable = Observable.just(new Book("The North Water", 2016), new Book("Origin", 2017), new Book("Sleeping Beauties", 2017)); Observable<Book> bookObservable = Observable
.just(
new Book("The North Water", 2016),
new Book("Origin", 2017),
new Book("Sleeping Beauties", 2017));
TestSubscriber<Map> subscriber = TestSubscriber.create(); TestSubscriber<Map> subscriber = TestSubscriber.create();
// when // when
Observable multiMapObservable = bookObservable.toMultimap(Book::getYear, Book::getTitle, () -> new HashMap(), (key) -> new ArrayList()); Observable multiMapObservable = bookObservable
.toMultimap(Book::getYear, Book::getTitle, () -> new HashMap<>(), (key) -> new ArrayList<>());
multiMapObservable.subscribe(subscriber); multiMapObservable.subscribe(subscriber);
@ -187,7 +199,6 @@ public class RxAggregateOperatorsTest {
put(2017, Arrays.asList("Origin", "Sleeping Beauties")); put(2017, Arrays.asList("Origin", "Sleeping Beauties"));
} }
}); });
} }
class Book { class Book {