remove isLocked

Author: davidmoten

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

@@ -190,7 +190,6 @@ private OnSubscribeRedo(Observable<T> source, Func1<? super Observable<? extends
 
     @Override
     public void call(final Subscriber<? super T> child) {
-        final AtomicBoolean isLocked = new AtomicBoolean(true);
         final AtomicBoolean resumeBoundary = new AtomicBoolean(true);
         // incremented when requests are made, decremented when requests are fulfilled
         final AtomicLong consumerCapacity = new AtomicLong(0l);
@@ -298,7 +297,6 @@ public void onNext(Notification<?> t) {
                                 else if (t.isOnError() && stopOnError)
                                     child.onError(t.getThrowable());
                                 else {
-                                    isLocked.set(false);
                                     filteredTerminals.onNext(t);
                                 }
                             }
@@ -328,7 +326,7 @@ public void onError(Throwable e) {
 
                     @Override
                     public void onNext(Object t) {
-                        if (!isLocked.get() && !child.isUnsubscribed()) {
+                        if (!child.isUnsubscribed()) {
                             if (consumerCapacity.get() > 0) {
                                 worker.schedule(subscribeToSource);
                             } else {