Skip to content

Commit b574974

Browse files
committed
Merge pull request #7 from abersnaze/undo_return_change
Change the return value back to an Observer because it was causing run time errors.
2 parents 00139f1 + b855611 commit b574974

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/main/java/rx/plugins/DebugNotification.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
import rx.Observable;
1616
import rx.Observable.OnSubscribe;
1717
import rx.Observable.Operator;
18+
import rx.Observer;
1819
import rx.Subscriber;
1920
import rx.observers.SafeSubscriber;
2021
import rx.operators.DebugSubscriber;
@@ -99,8 +100,7 @@ private DebugNotification(Subscriber o, Operator<? extends T, ?> from, Kind kind
99100
this.n = n;
100101
}
101102

102-
@SuppressWarnings("rawtypes")
103-
public Subscriber getObserver() {
103+
public Observer<?> getObserver() {
104104
return observer;
105105
}
106106

src/main/java/rx/plugins/SimpleDebugNotificationListener.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ public <T> SimpleContext<?> start(DebugNotification<T> n) {
3535
Queue<SimpleContext<?>> notifications = notificationsByObservable.get(n.getObserver());
3636
if (notifications == null) {
3737
notifications = new LinkedBlockingQueue<SimpleContext<?>>();
38-
notificationsByObservable.put(n.getObserver(), notifications);
38+
notificationsByObservable.put((Subscriber<?>) n.getObserver(), notifications);
3939
}
4040
notifications.add(context);
4141
return context;

0 commit comments

Comments
 (0)