fixup: avoid sync optimization for now

Author: ronag

lib/internal/streams/operators.js

@@ -57,13 +57,7 @@ module.exports.map = function map(stream, fn, options) {
     try {
       reading = true;
       while (queue.length && !ret.destroyed) {
-        let entry = queue.shift();
-
-        if (typeof entry.then === 'function') {
-          entry = await entry;
-        }
-
-        const [err, val] = entry;
+        const [err, val] = await queue.shift();
         if (err) {
           ret.destroy(err);
         } else if (!ret.push(val)) {
@@ -80,7 +74,7 @@ module.exports.map = function map(stream, fn, options) {
 
   async function wrap (val) {
     try {
-      return [null, await val];
+      return [null, await fn(val, { signal })];
     } catch (err) {
       return [err, null];
     }
@@ -100,16 +94,7 @@ module.exports.map = function map(stream, fn, options) {
         return;
       }
 
-      try {
-        val = fn(val, { signal });
-        if (val && typeof val.then === 'function') {
-          enqueue(wrap(val));
-        } else {
-          enqueue([null, val]);
-        }
-      } catch (err) {
-        enqueue([err, null]);
-      }
+      enqueue(wrap(val));
     }
   }