Unlock input reader after transforming stream

Author: twiss

lib/streams.js

@@ -257,6 +257,7 @@ function transform(input, process = () => undefined, finish = () => undefined) {
       async pull(controller) {
         if (allDone) {
           controller.close();
+          input.releaseLock();
           return;
         }
         try {
@@ -276,6 +277,7 @@ function transform(input, process = () => undefined, finish = () => undefined) {
               // `close` here. Otherwise, it will get called in the
               // next call to `pull`, above (since `allDone == true`).
               controller.close();
+              input.releaseLock();
               return;
             }
           }