Some cleaning up

mttkay · mttkay · commit 135b6c13e03d · 2014-03-12T18:29:41.000+01:00
diff --git a/rxjava-contrib/rxjava-android/src/main/java/rx/operators/OperatorWeakBinding.java b/rxjava-contrib/rxjava-android/src/main/java/rx/operators/OperatorWeakBinding.java
@@ -52,7 +52,7 @@ private WeakSubscriber(Subscriber<? super T> source) {
 
         @Override
         public void onCompleted() {
-            Subscriber<? super T> sub = subscriberRef.get();
+            final Subscriber<? super T> sub = subscriberRef.get();
             if (shouldForwardNotification(sub)) {
                 sub.onCompleted();
             } else {
@@ -62,7 +62,7 @@ public void onCompleted() {
 
         @Override
         public void onError(Throwable e) {
-            Subscriber<? super T> sub = subscriberRef.get();
+            final Subscriber<? super T> sub = subscriberRef.get();
             if (shouldForwardNotification(sub)) {
                 sub.onError(e);
             } else {
@@ -72,7 +72,7 @@ public void onError(Throwable e) {
 
         @Override
         public void onNext(T t) {
-            Subscriber<? super T> sub = subscriberRef.get();
+            final Subscriber<? super T> sub = subscriberRef.get();
             if (shouldForwardNotification(sub)) {
                 sub.onNext(t);
             } else {
@@ -90,7 +90,8 @@ private void handleLostBinding(Subscriber<? super T> sub, String context) {
                 Log.d(LOG_TAG, "subscriber gone; skipping " + context);
             } else {
                 final R r = boundRef.get();
-                if (r != null) { // the predicate failed to validate
+                if (r != null) {
+                    // the predicate failed to validate
                     Log.d(LOG_TAG, "bound component has become invalid; skipping " + context);
                 } else {
                     Log.d(LOG_TAG, "bound component gone; skipping " + context);
