Lines Matching refs:options
44 function compose(stream, options) {
45 if (options != null) {
46 validateObject(options, 'options');
48 if (options?.signal != null) {
49 validateAbortSignal(options.signal, 'options.signal');
58 if (options?.signal) {
61 options.signal,
69 function map(fn, options) {
74 if (options != null) {
75 validateObject(options, 'options');
77 if (options?.signal != null) {
78 validateAbortSignal(options.signal, 'options.signal');
82 if (options?.concurrency != null) {
83 concurrency = MathFloor(options.concurrency);
87 if (options?.highWaterMark != null) {
88 highWaterMark = MathFloor(options.highWaterMark);
91 validateInteger(concurrency, 'options.concurrency', 1);
92 validateInteger(highWaterMark, 'options.highWaterMark', 0);
97 const signal = AbortSignal.any([options?.signal].filter(Boolean));
219 function asIndexedPairs(options = undefined) {
220 if (options != null) {
221 validateObject(options, 'options');
223 if (options?.signal != null) {
224 validateAbortSignal(options.signal, 'options.signal');
230 if (options?.signal?.aborted) {
231 throw new AbortError({ cause: options.signal.reason });
238 async function some(fn, options = undefined) {
239 for await (const unused of filter.call(this, fn, options)) {
245 async function every(fn, options = undefined) {
253 }, options));
256 async function find(fn, options) {
257 for await (const result of filter.call(this, fn, options)) {
263 async function forEach(fn, options) {
268 async function forEachFn(value, options) {
269 await fn(value, options);
273 for await (const unused of map.call(this, forEachFn, options));
276 function filter(fn, options) {
281 async function filterFn(value, options) {
282 if (await fn(value, options)) {
287 return map.call(this, filterFn, options);
299 async function reduce(reducer, initialValue, options) {
304 if (options != null) {
305 validateObject(options, 'options');
307 if (options?.signal != null) {
308 validateAbortSignal(options.signal, 'options.signal');
312 if (options?.signal?.aborted) {
313 const err = new AbortError(undefined, { cause: options.signal.reason });
320 if (options?.signal) {
322 options.signal.addEventListener('abort', () => ac.abort(), opts);
328 if (options?.signal?.aborted) {
347 async function toArray(options) {
348 if (options != null) {
349 validateObject(options, 'options');
351 if (options?.signal != null) {
352 validateAbortSignal(options.signal, 'options.signal');
357 if (options?.signal?.aborted) {
358 throw new AbortError(undefined, { cause: options.signal.reason });
365 function flatMap(fn, options) {
366 const values = map.call(this, fn, options);
387 function drop(number, options = undefined) {
388 if (options != null) {
389 validateObject(options, 'options');
391 if (options?.signal != null) {
392 validateAbortSignal(options.signal, 'options.signal');
397 if (options?.signal?.aborted) {
401 if (options?.signal?.aborted) {
411 function take(number, options = undefined) {
412 if (options != null) {
413 validateObject(options, 'options');
415 if (options?.signal != null) {
416 validateAbortSignal(options.signal, 'options.signal');
421 if (options?.signal?.aborted) {
425 if (options?.signal?.aborted) {