stream: avoid constructing extra promise in createPromiseCallback

Author: aduh95

lib/internal/per_context/primordials.js

@@ -243,6 +243,12 @@ function copyPrototype(src, dest, prefix) {
   copyPrototype(original.prototype, primordials, `${name}Prototype`);
 });
 
+{
+  const { Promise } = primordials;
+  const OriginalPromiseTry = Promise.try;
+  primordials.BindPromiseTry = (fn) => bind(OriginalPromiseTry, Promise, fn);
+}
+
 // Create copies of abstract intrinsic objects that are not directly exposed
 // on the global object.
 // Refs: https://tc39.es/ecma262/#sec-%typedarray%-intrinsic-object

lib/internal/webstreams/util.js

@@ -7,9 +7,12 @@ const {
   ArrayPrototypePush,
   ArrayPrototypeShift,
   AsyncIteratorPrototype,
+  BindPromiseTry,
   MathMax,
   NumberIsNaN,
   PromisePrototypeThen,
+  PromiseReject,
+  PromiseResolve,
   ReflectApply,
   ReflectGet,
   Symbol,
@@ -164,7 +167,16 @@ function enqueueValueWithSize(controller, value, size) {
 
 function createPromiseCallback(name, fn, thisArg) {
   validateFunction(fn, name);
-  return async (...args) => ReflectApply(fn, thisArg, args);
+  if (thisArg === undefined) {
+    return BindPromiseTry(fn);
+  }
+  return (...args) => {
+    try {
+      return PromiseResolve(ReflectApply(fn, thisArg, args));
+    } catch (err) {
+      return PromiseReject(err);
+    }
+  };
 }
 
 function isPromisePending(promise) {