We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1c00aa6 commit b195ff8Copy full SHA for b195ff8
rxjava-core/src/main/java/rx/subjects/AsyncSubject.java
@@ -63,8 +63,8 @@ public static <T> AsyncSubject<T> create() {
63
@Override
64
public void call(SubjectObserver<T> o) {
65
Object v = state.get();
66
- o.accept(v, state.nl);
67
- NotificationLite<T> nl = NotificationLite.instance();
+ NotificationLite<T> nl = state.nl;
+ o.accept(v, nl);
68
if (v == null || (!nl.isCompleted(v) && !nl.isError(v))) {
69
o.onCompleted();
70
}
0 commit comments