DebugHook got miswired before

ReactiveX · Jun 17, 2014 · 43b75a9 · 43b75a9
1 parent 92e11ea
commit 43b75a9
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);
     }