Socket
Socket
Sign inDemoInstall

asynciterator

Package Overview
Dependencies
Maintainers
1
Versions
34
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

asynciterator - npm Package Compare versions

Comparing version 3.6.2 to 3.7.0

13

dist/asynciterator.d.ts

@@ -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 {};

5

dist/linkedlist.d.ts

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc