@@ -1715,40 +1715,41 @@ public void onNext(Map<Integer, Observable<Integer>> integerObservableMap) {
1715
1715
}
1716
1716
});
1717
1717
1718
- Observable <Map <Integer , Observable <Integer >>> mapObservable = Observable .range (0 , 10 )
1719
- .groupBy (new Func1 <Integer , Integer >() {
1720
- @ Override
1721
- public Integer call (Integer pair ) {
1722
- return pair % 2 ;
1723
- }
1724
- })
1725
- .toMap (new Func1 <GroupedObservable <Integer , Integer >, Integer >() {
1726
- @ Override
1727
- public Integer call (GroupedObservable <Integer , Integer > group ) {
1728
- return group .getKey ();
1729
- }
1730
- },
1731
- new Func1 <GroupedObservable <Integer , Integer >, Observable <Integer >>() {
1732
- @ Override
1733
- public Observable <Integer > call (GroupedObservable <Integer , Integer > integerGroup ) {
1734
- return integerGroup .map (
1735
- new Func1 <Integer , Integer >() {
1736
- @ Override
1737
- public Integer call (Integer integer ) {
1738
- return integer * 10 ;
1739
- }
1740
- });
1741
- }
1742
- }
1743
- );
1718
+ Observable <Map <Integer , Observable <Integer >>> mapObservable =
1719
+ Observable .range (0 , 10 )
1720
+ .groupBy (new Func1 <Integer , Integer >() {
1721
+ @ Override
1722
+ public Integer call (Integer pair ) {
1723
+ return pair % 2 ;
1724
+ }
1725
+ })
1726
+ .toMap (new Func1 <GroupedObservable <Integer , Integer >, Integer >() {
1727
+ @ Override
1728
+ public Integer call (GroupedObservable <Integer , Integer > group ) {
1729
+ return group .getKey ();
1730
+ }
1731
+ },
1732
+ new Func1 <GroupedObservable <Integer , Integer >, Observable <Integer >>() {
1733
+ @ Override
1734
+ public Observable <Integer > call (GroupedObservable <Integer , Integer > integerGroup ) {
1735
+ return integerGroup .map (
1736
+ new Func1 <Integer , Integer >() {
1737
+ @ Override
1738
+ public Integer call (Integer integer ) {
1739
+ return integer * 10 ;
1740
+ }
1741
+ });
1742
+ }
1743
+ }
1744
+ );
1744
1745
1745
1746
mapObservable .subscribe (outer );
1746
1747
1747
1748
inner1 .assertNoErrors ();
1748
1749
inner1 .assertCompleted ();
1749
1750
1750
- inner1 .assertReceivedOnNext (Arrays .asList (0 ,20 ,40 ,60 ,80 ));
1751
- inner2 .assertReceivedOnNext (Arrays .asList (10 ,30 ,50 ,70 ,90 ));
1751
+ inner1 .assertReceivedOnNext (Arrays .asList (0 , 20 , 40 , 60 , 80 ));
1752
+ inner2 .assertReceivedOnNext (Arrays .asList (10 , 30 , 50 , 70 , 90 ));
1752
1753
1753
1754
outer .assertNoErrors ();
1754
1755
outer .assertCompleted ();
0 commit comments