doNotSwallowError correction

yogeshpaliyal · Feb 1, 2017 · a70cd42 · a70cd42
1 parent 4661599
commit a70cd42
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/rx2-android-networking/src/main/java/com/rx2androidnetworking/Rx2InternalNetworking.java b/rx2-android-networking/src/main/java/com/rx2androidnetworking/Rx2InternalNetworking.java
@@ -173,7 +173,7 @@ static final class SimpleANObservable<T> extends Observable<T> {
         @Override
         protected void subscribeActual(Observer<? super T> observer) {
             observer.onSubscribe(new ANDisposable(this.call));
-            boolean dontSwallowError = false;
+            boolean doNotSwallowError = false;
             Response okHttpResponse = null;
             try {
                 final long startTime = System.currentTimeMillis();
@@ -219,7 +219,7 @@ protected void subscribeActual(Observer<? super T> observer) {
                             observer.onNext(response.getResult());
                         }
                         if (!call.isCanceled()) {
-                            dontSwallowError = true;
+                            doNotSwallowError = true;
                             observer.onComplete();
                         }
                     }
@@ -230,7 +230,7 @@ protected void subscribeActual(Observer<? super T> observer) {
                 }
             } catch (Exception e) {
                 Exceptions.throwIfFatal(e);
-                if (dontSwallowError) {
+                if (doNotSwallowError) {
                     RxJavaPlugins.onError(e);
                 } else if (!call.isCanceled()) {
                     try {
@@ -259,7 +259,7 @@ static final class DownloadANObservable<T> extends Observable<T> {
         @Override
         protected void subscribeActual(Observer<? super T> observer) {
             observer.onSubscribe(new ANDisposable(this.call));
-            boolean dontSwallowError = false;
+            boolean doNotSwallowError = false;
             Response okHttpResponse;
             try {
                 final long startTime = System.currentTimeMillis();
@@ -293,7 +293,7 @@ protected void subscribeActual(Observer<? super T> observer) {
                         observer.onNext(response.getResult());
                     }
                     if (!call.isCanceled()) {
-                        dontSwallowError = true;
+                        doNotSwallowError = true;
                         observer.onComplete();
                     }
                 }
@@ -311,7 +311,7 @@ protected void subscribeActual(Observer<? super T> observer) {
                 }
             } catch (Exception e) {
                 Exceptions.throwIfFatal(e);
-                if (dontSwallowError) {
+                if (doNotSwallowError) {
                     RxJavaPlugins.onError(e);
                 } else if (!call.isCanceled()) {
                     try {