diff --git a/rxjava-core/src/main/java/rx/operators/OperationFilter.java b/rxjava-core/src/main/java/rx/operators/OperationFilter.java index 3d6c0ffb791..64cd70d1ffc 100644 --- a/rxjava-core/src/main/java/rx/operators/OperationFilter.java +++ b/rxjava-core/src/main/java/rx/operators/OperationFilter.java @@ -37,7 +37,6 @@ private static class Filter implements Func1, Subscription> { private final Observable that; private final Func1 predicate; - private final AtomicObservableSubscription subscription = new AtomicObservableSubscription(); public Filter(Observable that, Func1 predicate) { this.that = that; @@ -45,6 +44,7 @@ public Filter(Observable that, Func1 predicate) { } public Subscription call(final Observer observer) { + final AtomicObservableSubscription subscription = new AtomicObservableSubscription(); return subscription.wrap(that.subscribe(new Observer() { public void onNext(T value) { try {