From 43b75a9c73d367664f0e824307295b061e3d1fde Mon Sep 17 00:00:00 2001 From: Matt Jacobs Date: Tue, 17 Jun 2014 11:30:59 -0700 Subject: [PATCH] DebugHook got miswired before --- .../src/main/java/rx/plugins/DebugNotification.java | 2 +- 1 file changed, 1 insertion(+), 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 index cc011d48fd..ba195aa384 100644 --- 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 DebugNotification createSubscribe(Observer o, o = ds.getActual(); } if (sourceFunc instanceof DebugHook.DebugOnSubscribe) { - sourceFunc = (OnSubscribe) ((SafeSubscriber) sourceFunc).getActual(); + sourceFunc = ((DebugHook.DebugOnSubscribe) sourceFunc).getActual(); } return new DebugNotification(o, from, Kind.Subscribe, null, null, to, source, sourceFunc); }