Upgrade to RxJava 2.1.9, minor cleanup

Author: akarnokd

Diff for: 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.18.4"
+    compile "com.github.akarnokd:rxjava2-extensions:0.18.5"
 }
 ```
 

Diff for: build.gradle

@@ -48,8 +48,8 @@ apply plugin: 'osgi'
 dependencies {
     signature 'org.codehaus.mojo.signature:java16:1.1@signature'
 
-    compile "org.reactivestreams:reactive-streams:1.0.1"
-    compile "io.reactivex.rxjava2:rxjava:2.1.8"
+    compile "org.reactivestreams:reactive-streams:1.0.2"
+    compile "io.reactivex.rxjava2:rxjava:2.1.9"
 
     testCompile group: 'junit', name: 'junit', version: '4.12'
 

Diff for: gradle.properties

@@ -1 +1 @@
-version=0.18.4
+version=0.18.5

Diff for: src/main/java/hu/akarnokd/rxjava2/joins/PatternN.java

@@ -37,7 +37,8 @@ public PatternN(List<Observable<? extends Object>> observables, Observable<? ext
     }
 
     /**
-     * @return the number of observables in this pattern.
+     * The number of observables in this pattern.
+     * @return the number of observables in this pattern
      */
     int size() {
         return observables.size();

Diff for: src/main/java/hu/akarnokd/rxjava2/operators/FlowableIndexOf.java

@@ -53,7 +53,6 @@ protected void subscribeActual(Subscriber<? super Long> s) {
 
     static final class IndexOfSubscriber<T> extends DeferredScalarSubscriber<T, Long> {
 
-        /** */
         private static final long serialVersionUID = 4809092721669178986L;
 
         final Predicate<? super T> predicate;
@@ -86,7 +85,7 @@ public void onNext(T t) {
                 return;
             }
         }
-        
+
         @Override
         public void onComplete() {
             if (!found) {

Diff for: src/main/java/hu/akarnokd/rxjava2/operators/FlowableRefCountTimeout.java

@@ -31,7 +31,7 @@
 /**
  * A refCount implementation that allows connecting to the source after the specified
  * number of Subscribers subscribed and allows disconnecting after a specified
- * grace period
+ * grace period.
  * @since 0.17.0
  */
 final class FlowableRefCountTimeout<T> extends Flowable<T> implements FlowableTransformer<T, T> {

Diff for: src/main/java/hu/akarnokd/rxjava2/operators/FlowableSpanout.java

@@ -27,7 +27,7 @@
 import io.reactivex.internal.subscriptions.SubscriptionHelper;
 
 /**
- * Makes sure there is at least the given amount of time between emissions of the upstream elements:
+ * Makes sure there is at least the given amount of time between emissions of the upstream elements.
  * <pre><code>
  * a-b-c-d-e--f----g-|
  * spanout(---)

Diff for: src/main/java/hu/akarnokd/rxjava2/operators/ObservableIndexOf.java

@@ -51,7 +51,6 @@ protected void subscribeActual(Observer<? super Long> s) {
 
     static final class IndexOfObserver<T> extends DeferredScalarObserver<T, Long> {
 
-        /** */
         private static final long serialVersionUID = 4809092721669178986L;
 
         final Predicate<? super T> predicate;
@@ -84,7 +83,7 @@ public void onNext(T t) {
                 return;
             }
         }
-        
+
         @Override
         public void onComplete() {
             if (!found) {