diff --git a/lib/internal/streams/operators.js b/lib/internal/streams/operators.js index 14d6b86416f11d..f93e2a1af9fc78 100644 --- a/lib/internal/streams/operators.js +++ b/lib/internal/streams/operators.js @@ -156,12 +156,12 @@ async function some(fn, options) { // Note that some does short circuit but also closes the iterator if it does const ac = new AbortController(); if (options?.signal) { - options?.signal?.addEventListener('abort', ac.abort.bind(ac), { + options?.signal?.addEventListener('abort', () => ac.abort(), { [kWeakHandler]: this, once: true, }); } - const mapped = this.map(fn, { ...(options ?? {}), signal: ac.signal }); + const mapped = this.map(fn, { ...options, signal: ac.signal }); for await (const result of mapped) { if (result) { ac.abort();