Upgrade to RxJava 2.1.1, adjust emitters

Author: akarnokd

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.17.0"
+    compile "com.github.akarnokd:rxjava2-extensions:0.17.1"
 }
 ```
 

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.1.0"
+    compile "io.reactivex.rxjava2:rxjava:2.1.1"
 
     testCompile group: 'junit', name: 'junit', version: '4.12'
 

gradle.properties

@@ -1 +1 @@
-version=0.17.0
+version=0.17.1

src/main/java/hu/akarnokd/rxjava2/basetypes/NonoCreate.java

@@ -80,16 +80,23 @@ public void onComplete() {
 
         @Override
         public void onError(Throwable t) {
+            if (!tryOnError(t)) {
+                RxJavaPlugins.onError(t);
+            }
+        }
+
+        @Override
+        public boolean tryOnError(Throwable t) {
             Disposable d = getAndSet(DisposableHelper.DISPOSED);
             if (d != DisposableHelper.DISPOSED) {
                 actual.onError(t);
 
                 if (d != null) {
                     d.dispose();
                 }
-            } else {
-                RxJavaPlugins.onError(t);
+                return true;
             }
+            return false;
         }
 
         @Override

src/main/java/hu/akarnokd/rxjava2/basetypes/PerhapsCreate.java

@@ -81,16 +81,23 @@ public void onSuccess(T t) {
 
         @Override
         public void onError(Throwable t) {
+            if (!tryOnError(t)) {
+                RxJavaPlugins.onError(t);
+            }
+        }
+
+        @Override
+        public boolean tryOnError(Throwable t) {
             Disposable d = resource.getAndSet(DisposableHelper.DISPOSED);
             if (d != DisposableHelper.DISPOSED) {
                 actual.onError(t);
 
                 if (d != null) {
                     d.dispose();
                 }
-            } else {
-                RxJavaPlugins.onError(t);
+                return true;
             }
+            return false;
         }
 
         @Override

src/main/java/hu/akarnokd/rxjava2/basetypes/SoloCreate.java

@@ -81,16 +81,23 @@ public void onSuccess(T t) {
 
         @Override
         public void onError(Throwable t) {
+            if (!tryOnError(t)) {
+                RxJavaPlugins.onError(t);
+            }
+        }
+
+        @Override
+        public boolean tryOnError(Throwable t) {
             Disposable d = resource.getAndSet(DisposableHelper.DISPOSED);
             if (d != DisposableHelper.DISPOSED) {
                 actual.onError(t);
 
                 if (d != null) {
                     d.dispose();
                 }
-            } else {
-                RxJavaPlugins.onError(t);
+                return true;
             }
+            return false;
         }
 
         @Override