asynciterator
Advanced tools
Comparing version 3.6.2 to 3.7.0
@@ -7,3 +7,5 @@ /** | ||
import { EventEmitter } from 'events'; | ||
import { LinkedList } from './linkedlist'; | ||
import type { Task, TaskScheduler } from './taskscheduler'; | ||
export { LinkedList }; | ||
/** Schedules the given task for asynchronous execution. */ | ||
@@ -286,2 +288,9 @@ export declare function scheduleTask(task: Task): void; | ||
/** | ||
* Returns a new iterator containing all of the unique items in the original iterator. | ||
* @param by - The derived value by which to determine uniqueness (e.g., stringification). | ||
Defaults to the identity function. | ||
* @returns An iterator with duplicates filtered out. | ||
*/ | ||
uniq(by?: (item: T) => any): AsyncIterator<T>; | ||
/** | ||
Prepends the items after those of the current iterator. | ||
@@ -745,3 +754,4 @@ After this operation, only read the returned iterator instead of the current one. | ||
protected _source: InternalSource<T> | null; | ||
constructor(source?: MaybePromise<IterableSource<T>>); | ||
protected _destroySource: boolean; | ||
constructor(source?: MaybePromise<IterableSource<T>>, opts?: SourcedIteratorOptions); | ||
set source(value: IterableSource<T>); | ||
@@ -835,2 +845,1 @@ read(): T | null; | ||
}): object is Iterator<T>; | ||
export {}; |
@@ -1,2 +0,5 @@ | ||
export default class LinkedList<V> { | ||
/** | ||
* A list with O(1) push and shift operations. | ||
*/ | ||
export declare class LinkedList<V> { | ||
private _length; | ||
@@ -3,0 +6,0 @@ private _head; |
@@ -1,2 +0,5 @@ | ||
export default class LinkedList { | ||
/** | ||
* A list with O(1) push and shift operations. | ||
*/ | ||
export class LinkedList { | ||
constructor() { | ||
@@ -3,0 +6,0 @@ this._length = 0; |
@@ -1,3 +0,3 @@ | ||
export default function createTaskScheduler(): TaskScheduler; | ||
export declare function createTaskScheduler(): TaskScheduler; | ||
export declare type Task = () => void; | ||
export declare type TaskScheduler = (task: Task) => void; |
const resolved = Promise.resolve(undefined); | ||
// Returns a function that asynchronously schedules a task | ||
export default function createTaskScheduler() { | ||
export function createTaskScheduler() { | ||
// Use or create a microtask scheduler | ||
@@ -5,0 +5,0 @@ const scheduleMicrotask = typeof queueMicrotask === 'function' ? |
{ | ||
"name": "asynciterator", | ||
"version": "3.6.2", | ||
"version": "3.7.0", | ||
"description": "An asynchronous iterator library for advanced object pipelines.", | ||
@@ -5,0 +5,0 @@ "author": "Ruben Verborgh <ruben@verborgh.org> (https://ruben.verborgh.org/)", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
212294
4958