@@ -52,7 +52,7 @@ private WeakSubscriber(Subscriber<? super T> source) {
52
52
53
53
@ Override
54
54
public void onCompleted () {
55
- Subscriber <? super T > sub = subscriberRef .get ();
55
+ final Subscriber <? super T > sub = subscriberRef .get ();
56
56
if (shouldForwardNotification (sub )) {
57
57
sub .onCompleted ();
58
58
} else {
@@ -62,7 +62,7 @@ public void onCompleted() {
62
62
63
63
@ Override
64
64
public void onError (Throwable e ) {
65
- Subscriber <? super T > sub = subscriberRef .get ();
65
+ final Subscriber <? super T > sub = subscriberRef .get ();
66
66
if (shouldForwardNotification (sub )) {
67
67
sub .onError (e );
68
68
} else {
@@ -72,7 +72,7 @@ public void onError(Throwable e) {
72
72
73
73
@ Override
74
74
public void onNext (T t ) {
75
- Subscriber <? super T > sub = subscriberRef .get ();
75
+ final Subscriber <? super T > sub = subscriberRef .get ();
76
76
if (shouldForwardNotification (sub )) {
77
77
sub .onNext (t );
78
78
} else {
@@ -90,7 +90,8 @@ private void handleLostBinding(Subscriber<? super T> sub, String context) {
90
90
Log .d (LOG_TAG , "subscriber gone; skipping " + context );
91
91
} else {
92
92
final R r = boundRef .get ();
93
- if (r != null ) { // the predicate failed to validate
93
+ if (r != null ) {
94
+ // the predicate failed to validate
94
95
Log .d (LOG_TAG , "bound component has become invalid; skipping " + context );
95
96
} else {
96
97
Log .d (LOG_TAG , "bound component gone; skipping " + context );
0 commit comments