Unlock input reader after transforming stream

Author: twiss

lib/streams.js

@@ -252,6 +252,7 @@ function transform(input, process = () => undefined, finish = () => undefined) {
       async pull(controller) {
         if (allDone) {
           controller.close();
+          input.releaseLock();
           return;
         }
         try {
@@ -265,6 +266,7 @@ function transform(input, process = () => undefined, finish = () => undefined) {
             }
             if (done) {
               controller.close();
+              input.releaseLock();
               return;
             }
           }