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

DebugHook got miswired before
ReactiveX · Jun 17, 2014 · 9be2c3d · 9be2c3d
2 parents 6a5983e + 43b75a9
commit 9be2c3d
Showing 1 changed file with 1 addition and 1 deletion.
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);
     }