Changing line 38 to try and fix build

benjchristensen · benjchristensen · commit 3b628bea663e · 2014-03-05T22:45:27.000-08:00
Odd Jenkins build failures even though command-line build works fine:

```
:rxjava:rxjava-contrib:rxjava-debug:compileJava/mnt/builds/slave/workspace/OSS-RxJava-release/rxjava-contrib/rxjava-debug/src/main/java/rx/plugins/DebugNotification.java:38: ')' expected
            sourceFunc = ((DebugHook&lt;C&gt;.DebugOnSubscribe&lt;T&gt;) sourceFunc).getActual();
                                       ^
/mnt/builds/slave/workspace/OSS-RxJava-release/rxjava-contrib/rxjava-debug/src/main/java/rx/plugins/DebugNotification.java:38: ')' expected
            sourceFunc = ((DebugHook&lt;C&gt;.DebugOnSubscribe&lt;T&gt;) sourceFunc).getActual();
                                        ^
/mnt/builds/slave/workspace/OSS-RxJava-release/rxjava-contrib/rxjava-debug/src/main/java/rx/plugins/DebugNotification.java:38: illegal start of expression
            sourceFunc = ((DebugHook&lt;C&gt;.DebugOnSubscribe&lt;T&gt;) sourceFunc).getActual();
                                                           ^
/mnt/builds/slave/workspace/OSS-RxJava-release/rxjava-contrib/rxjava-debug/src/main/java/rx/plugins/DebugNotification.java:38: not a statement
            sourceFunc = ((DebugHook&lt;C&gt;.DebugOnSubscribe&lt;T&gt;) sourceFunc).getActual();
                                                             ^
/mnt/builds/slave/workspace/OSS-RxJava-release/rxjava-contrib/rxjava-debug/src/main/java/rx/plugins/DebugNotification.java:38: ';' expected
            sourceFunc = ((DebugHook&lt;C&gt;.DebugOnSubscribe&lt;T&gt;) sourceFunc).getActual();
                                                                       ^
5 errors
 FAILED
```
diff --git a/src/main/java/rx/plugins/DebugNotification.java b/src/main/java/rx/plugins/DebugNotification.java
@@ -35,7 +35,7 @@ public static <T, C> DebugNotification<T> createSubscribe(Observer<? super T> o,
             o = ds.getActual();
         }
         if (sourceFunc instanceof DebugHook.DebugOnSubscribe) {
-            sourceFunc = ((DebugHook<C>.DebugOnSubscribe<T>) sourceFunc).getActual();
+            sourceFunc = (OnSubscribe<T>) ((SafeSubscriber) 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
`@@ -35,7 +35,7 @@ public static <T, C> DebugNotification<T> createSubscribe(Observer<? super T> o,`
`35`	`35`	`o = ds.getActual();`
`36`	`36`	`}`
`37`	`37`	`if (sourceFunc instanceof DebugHook.DebugOnSubscribe) {`
`38`		`- sourceFunc = ((DebugHook<C>.DebugOnSubscribe<T>) sourceFunc).getActual();`
	`38`	`+ sourceFunc = (OnSubscribe<T>) ((SafeSubscriber) sourceFunc).getActual();`
`39`	`39`	`}`
`40`	`40`	`return new DebugNotification<T>(o, from, Kind.Subscribe, null, null, to, source, sourceFunc);`
`41`	`41`	`}`