Skip to content

Commit 0794d9f

Browse files
zsxwingbenjchristensen
authored andcommitted
Fix Rx serialization bug in takeUntil again
1 parent 4a593af commit 0794d9f

File tree

1 file changed

+1
-18
lines changed

1 file changed

+1
-18
lines changed

src/main/java/rx/internal/operators/OperatorTakeUntil.java

Lines changed: 1 addition & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -36,24 +36,7 @@ public OperatorTakeUntil(final Observable<? extends E> other) {
3636

3737
@Override
3838
public Subscriber<? super T> call(final Subscriber<? super T> child) {
39-
final Subscriber<T> parent = new SerializedSubscriber<T>(child) {
40-
41-
@Override
42-
public void onCompleted() {
43-
child.onCompleted();
44-
}
45-
46-
@Override
47-
public void onError(Throwable e) {
48-
child.onError(e);
49-
}
50-
51-
@Override
52-
public void onNext(T t) {
53-
child.onNext(t);
54-
}
55-
56-
};
39+
final Subscriber<T> parent = new SerializedSubscriber<T>(child);
5740

5841
other.unsafeSubscribe(new Subscriber<E>(child) {
5942

0 commit comments

Comments
 (0)