Upgrade to RxJava 2.0.8

README.md

@@ -13,7 +13,7 @@ RxJava 2.x implementation of extra sources, operators and components and ports o
 
 ```
 dependencies {
-    compile "com.github.akarnokd:rxjava2-extensions:0.16.2"
+    compile "com.github.akarnokd:rxjava2-extensions:0.16.3"
 }
 ```
 

build.gradle

@@ -49,7 +49,7 @@ dependencies {
     signature 'org.codehaus.mojo.signature:java16:1.1@signature'
 
     compile "org.reactivestreams:reactive-streams:1.0.0"
-    compile "io.reactivex.rxjava2:rxjava:2.0.7"
+    compile "io.reactivex.rxjava2:rxjava:2.0.8"
 
     testCompile group: 'junit', name: 'junit', version: '4.12'
 

gradle.properties

@@ -1 +1 @@
-version=0.16.2
+version=0.16.3

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelSumDouble.java

@@ -21,6 +21,7 @@
 import io.reactivex.FlowableSubscriber;
 import io.reactivex.internal.subscriptions.*;
 import io.reactivex.parallel.ParallelFlowable;
+import io.reactivex.parallel.ParallelTransformer;
 
 /**
  * Sums numbers as longs on each parallel rail, or empty if the rail doesn't produce any data.
@@ -35,7 +36,7 @@ final class ParallelSumDouble<T extends Number> extends ParallelFlowable<Double>
     }
 
     @Override
-    public ParallelFlowable<Double> apply(ParallelFlowable<T> t) throws Exception {
+    public ParallelFlowable<Double> apply(ParallelFlowable<T> t) {
         return new ParallelSumDouble<T>(t);
     }
 

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelSumInteger.java

@@ -21,6 +21,7 @@
 import io.reactivex.FlowableSubscriber;
 import io.reactivex.internal.subscriptions.*;
 import io.reactivex.parallel.ParallelFlowable;
+import io.reactivex.parallel.ParallelTransformer;
 
 /**
  * Sums numbers as integers on each parallel rail, or empty if the rail doesn't produce any data.
@@ -35,7 +36,7 @@ final class ParallelSumInteger<T extends Number> extends ParallelFlowable<Intege
     }
 
     @Override
-    public ParallelFlowable<Integer> apply(ParallelFlowable<T> t) throws Exception {
+    public ParallelFlowable<Integer> apply(ParallelFlowable<T> t) {
         return new ParallelSumInteger<T>(t);
     }
 

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelSumLong.java

@@ -21,6 +21,7 @@
 import io.reactivex.FlowableSubscriber;
 import io.reactivex.internal.subscriptions.*;
 import io.reactivex.parallel.ParallelFlowable;
+import io.reactivex.parallel.ParallelTransformer;
 
 /**
  * Sums numbers as longs on each parallel rail, or empty if the rail doesn't produce any data.
@@ -35,7 +36,7 @@ final class ParallelSumLong<T extends Number> extends ParallelFlowable<Long> imp
     }
 
     @Override
-    public ParallelFlowable<Long> apply(ParallelFlowable<T> t) throws Exception {
+    public ParallelFlowable<Long> apply(ParallelFlowable<T> t) {
         return new ParallelSumLong<T>(t);
     }
 

src/main/java/hu/akarnokd/rxjava2/parallel/ParallelTransformers.java

@@ -16,6 +16,8 @@
 
 package hu.akarnokd.rxjava2.parallel;
 
+import io.reactivex.parallel.ParallelTransformer;
+
 /**
  * Transformers for RxJava 2 ParallelFlowable sequences.
  * @since 0.16.3