DMleadgen
46d973904b
Next.js website for Rocky Mountain Vending company featuring: - Product catalog with Stripe integration - Service areas and parts pages - Admin dashboard with Clerk authentication - SEO optimized pages with JSON-LD structured data Co-authored-by: Cursor <cursoragent@cursor.com>
64 lines
3.5 KiB
Text
64 lines
3.5 KiB
Text
import type nodeStream from "node:stream";
|
|
import type { BufferEncoding, Callback } from "../../../_internal/types.mjs";
|
|
import { EventEmitter } from "node:events";
|
|
interface ArrayOptions {
|
|
/** the maximum concurrent invocations of `fn` to call on the stream at once. **Default: 1**. */
|
|
concurrency?: number;
|
|
/** allows destroying the stream if the signal is aborted. */
|
|
signal?: AbortSignal;
|
|
}
|
|
export declare class _Readable extends EventEmitter implements nodeStream.Readable {
|
|
__unenv__: unknown;
|
|
readonly readableEncoding: BufferEncoding | null;
|
|
readonly readableEnded: boolean;
|
|
readonly readableFlowing: boolean | null;
|
|
readonly readableHighWaterMark: number;
|
|
readonly readableLength: number;
|
|
readonly readableObjectMode: boolean;
|
|
readonly readableAborted: boolean;
|
|
readonly readableDidRead: boolean;
|
|
readonly closed: boolean;
|
|
readonly errored: Error | null;
|
|
readable: boolean;
|
|
destroyed: boolean;
|
|
static from(_iterable: Iterable<any> | AsyncIterable<any>, options?: nodeStream.ReadableOptions);
|
|
constructor(_opts?: nodeStream.ReadableOptions);
|
|
_read(_size: number);
|
|
read(_size?: number);
|
|
setEncoding(_encoding: BufferEncoding);
|
|
pause();
|
|
resume();
|
|
isPaused(): boolean;
|
|
unpipe(_destination?: any);
|
|
unshift(_chunk: any, _encoding?: BufferEncoding);
|
|
wrap(_oldStream: any);
|
|
push(_chunk: any, _encoding?: BufferEncoding): boolean;
|
|
_destroy(_error?: any, _callback?: Callback<any>);
|
|
destroy(error?: Error);
|
|
pipe<T>(_destenition: T, _options?: {
|
|
end?: boolean
|
|
}): T;
|
|
compose<T extends NodeJS.ReadableStream>(stream: T | ((source: any) => void) | Iterable<T> | AsyncIterable<T>, options?: {
|
|
signal: AbortSignal
|
|
} | undefined): T;
|
|
[Symbol.asyncDispose]();
|
|
[Symbol.asyncIterator](): NodeJS.AsyncIterator<any>;
|
|
iterator(options?: {
|
|
destroyOnReturn?: boolean | undefined
|
|
} | undefined): NodeJS.AsyncIterator<any>;
|
|
map(fn: (data: any, options?: Pick<ArrayOptions, "signal"> | undefined) => any, options?: ArrayOptions | undefined): nodeStream.Readable;
|
|
filter(fn: (data: any, options?: Pick<ArrayOptions, "signal"> | undefined) => boolean, options?: ArrayOptions | undefined): nodeStream.Readable;
|
|
forEach(fn: (data: any, options?: Pick<ArrayOptions, "signal"> | undefined) => void | Promise<void>, options?: ArrayOptions | undefined): Promise<void>;
|
|
reduce(fn: (accumulator: any, data: any, options?: Pick<ArrayOptions, "signal"> | undefined) => any, initialValue?: any, options?: ArrayOptions | undefined): Promise<any>;
|
|
find(fn: (data: any, options?: Pick<ArrayOptions, "signal"> | undefined) => boolean, options?: ArrayOptions | undefined): Promise<any>;
|
|
findIndex(fn: (data: any, options?: Pick<ArrayOptions, "signal"> | undefined) => boolean, options?: ArrayOptions | undefined): Promise<number>;
|
|
some(fn: (data: any, options?: Pick<ArrayOptions, "signal"> | undefined) => boolean, options?: ArrayOptions | undefined): Promise<boolean>;
|
|
toArray(options?: Pick<ArrayOptions, "signal"> | undefined): Promise<any[]>;
|
|
every(fn: (data: any, options?: Pick<ArrayOptions, "signal"> | undefined) => boolean | Promise<boolean>, options?: ArrayOptions | undefined): Promise<boolean>;
|
|
flatMap(fn: (data: any, options?: Pick<ArrayOptions, "signal"> | undefined) => any, options?: ArrayOptions | undefined): nodeStream.Readable;
|
|
drop(limit: number, options?: Pick<ArrayOptions, "signal"> | undefined): nodeStream.Readable;
|
|
take(limit: number, options?: Pick<ArrayOptions, "signal"> | undefined): nodeStream.Readable;
|
|
asIndexedPairs(options?: Pick<ArrayOptions, "signal"> | undefined): nodeStream.Readable;
|
|
}
|
|
export declare const Readable: typeof nodeStream.Readable;
|
|
export {};
|