Merge pull request #1369 from mattrjacobs/fix-debug-hook

benjchristensen · benjchristensen · commit 9be2c3df26cb · 2014-06-17T12:20:17.000-07:00
DebugHook got miswired before
diff --git a/rxjava-contrib/rxjava-debug/src/main/java/rx/plugins/DebugNotification.java b/rxjava-contrib/rxjava-debug/src/main/java/rx/plugins/DebugNotification.java
@@ -37,7 +37,7 @@ public static <T, C> DebugNotification<T> createSubscribe(Observer<? super T> o,
             o = ds.getActual();
         }
         if (sourceFunc instanceof DebugHook.DebugOnSubscribe) {
-            sourceFunc = (OnSubscribe<T>) ((SafeSubscriber<T>) sourceFunc).getActual();
+            sourceFunc = ((DebugHook.DebugOnSubscribe) sourceFunc).getActual();
         }
         return new DebugNotification<T>(o, from, Kind.Subscribe, null, null, to, source, sourceFunc);
     }

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ public static <T, C> DebugNotification<T> createSubscribe(Observer<? super T> o,`
`37`	`37`	`o = ds.getActual();`
`38`	`38`	`}`
`39`	`39`	`if (sourceFunc instanceof DebugHook.DebugOnSubscribe) {`
`40`		`- sourceFunc = (OnSubscribe<T>) ((SafeSubscriber<T>) sourceFunc).getActual();`
	`40`	`+ sourceFunc = ((DebugHook.DebugOnSubscribe) sourceFunc).getActual();`
`41`	`41`	`}`
`42`	`42`	`return new DebugNotification<T>(o, from, Kind.Subscribe, null, null, to, source, sourceFunc);`
`43`	`43`	`}`