Fix NPE in SubjectSubscriptionManager

benjchristensen · benjchristensen · commit 56eebb5146fc · 2014-04-11T12:35:52.000-07:00
diff --git a/rxjava-core/src/main/java/rx/subjects/SubjectSubscriptionManager.java b/rxjava-core/src/main/java/rx/subjects/SubjectSubscriptionManager.java
@@ -94,7 +94,7 @@ public void call() {
                         }));
                         if (subscription.isUnsubscribed()) {
                             addedObserver = false;
-                            break;
+                            return;
                         }
                         // on subscribe add it to the map of outbound observers to notify
                         newState = current.addObserver(subscription, observer);

Original file line number	Diff line number	Diff line change
`@@ -94,7 +94,7 @@ public void call() {`
`94`	`94`	`}));`
`95`	`95`	`if (subscription.isUnsubscribed()) {`
`96`	`96`	`addedObserver = false;`
`97`		`- break;`
	`97`	`+ return;`
`98`	`98`	`}`
`99`	`99`	`// on subscribe add it to the map of outbound observers to notify`
`100`	`100`	`newState = current.addObserver(subscription, observer);`