summaryrefslogtreecommitdiff
path: root/op_crates/fetch/lib.deno_fetch.d.ts
diff options
context:
space:
mode:
Diffstat (limited to 'op_crates/fetch/lib.deno_fetch.d.ts')
-rw-r--r--op_crates/fetch/lib.deno_fetch.d.ts79
1 files changed, 53 insertions, 26 deletions
diff --git a/op_crates/fetch/lib.deno_fetch.d.ts b/op_crates/fetch/lib.deno_fetch.d.ts
index 30c031747..83739f2ec 100644
--- a/op_crates/fetch/lib.deno_fetch.d.ts
+++ b/op_crates/fetch/lib.deno_fetch.d.ts
@@ -37,12 +37,22 @@ interface ReadableStreamDefaultReader<R = any> {
releaseLock(): void;
}
+declare var ReadableStreamDefaultReader: {
+ prototype: ReadableStreamDefaultReader;
+ new <R>(stream: ReadableStream<R>): ReadableStreamDefaultReader<R>;
+};
+
interface ReadableStreamReader<R = any> {
cancel(): Promise<void>;
read(): Promise<ReadableStreamReadResult<R>>;
releaseLock(): void;
}
+declare var ReadableStreamReader: {
+ prototype: ReadableStreamReader;
+ new (): ReadableStreamReader;
+};
+
interface ReadableByteStreamControllerCallback {
(controller: ReadableByteStreamController): void | PromiseLike<void>;
}
@@ -55,6 +65,14 @@ interface UnderlyingByteSource {
type: "bytes";
}
+interface UnderlyingSink<W = any> {
+ abort?: WritableStreamErrorCallback;
+ close?: WritableStreamDefaultControllerCloseCallback;
+ start?: WritableStreamDefaultControllerStartCallback;
+ type?: undefined;
+ write?: WritableStreamDefaultControllerWriteCallback<W>;
+}
+
interface UnderlyingSource<R = any> {
cancel?: ReadableStreamErrorCallback;
pull?: ReadableStreamDefaultControllerCallback<R>;
@@ -77,6 +95,11 @@ interface ReadableStreamDefaultController<R = any> {
error(error?: any): void;
}
+declare var ReadableStreamDefaultController: {
+ prototype: ReadableStreamDefaultController;
+ new (): ReadableStreamDefaultController;
+};
+
interface ReadableByteStreamController {
readonly byobRequest: undefined;
readonly desiredSize: number | null;
@@ -85,6 +108,11 @@ interface ReadableByteStreamController {
error(error?: any): void;
}
+declare var ReadableByteStreamController: {
+ prototype: ReadableByteStreamController;
+ new (): ReadableByteStreamController;
+};
+
interface PipeOptions {
preventAbort?: boolean;
preventCancel?: boolean;
@@ -122,14 +150,9 @@ declare class ByteLengthQueuingStrategy
interface ReadableStream<R = any> {
readonly locked: boolean;
cancel(reason?: any): Promise<void>;
- getIterator(options?: { preventCancel?: boolean }): AsyncIterableIterator<R>;
- // getReader(options: { mode: "byob" }): ReadableStreamBYOBReader;
getReader(): ReadableStreamDefaultReader<R>;
pipeThrough<T>(
- {
- writable,
- readable,
- }: {
+ { writable, readable }: {
writable: WritableStream<R>;
readable: ReadableStream<T>;
},
@@ -174,28 +197,23 @@ interface WritableStreamErrorCallback {
(reason: any): void | PromiseLike<void>;
}
-interface UnderlyingSink<W = any> {
- abort?: WritableStreamErrorCallback;
- close?: WritableStreamDefaultControllerCloseCallback;
- start?: WritableStreamDefaultControllerStartCallback;
- type?: undefined;
- write?: WritableStreamDefaultControllerWriteCallback<W>;
-}
-
/** This Streams API interface provides a standard abstraction for writing
* streaming data to a destination, known as a sink. This object comes with
* built-in backpressure and queuing. */
-declare class WritableStream<W = any> {
- constructor(
- underlyingSink?: UnderlyingSink<W>,
- strategy?: QueuingStrategy<W>,
- );
+interface WritableStream<W = any> {
readonly locked: boolean;
abort(reason?: any): Promise<void>;
- close(): Promise<void>;
getWriter(): WritableStreamDefaultWriter<W>;
}
+declare var WritableStream: {
+ prototype: WritableStream;
+ new <W = any>(
+ underlyingSink?: UnderlyingSink<W>,
+ strategy?: QueuingStrategy<W>,
+ ): WritableStream<W>;
+};
+
/** This Streams API interface represents a controller allowing control of a
* WritableStream's state. When constructing a WritableStream, the underlying
* sink is given a corresponding WritableStreamDefaultController instance to
@@ -218,16 +236,25 @@ interface WritableStreamDefaultWriter<W = any> {
write(chunk: W): Promise<void>;
}
-declare class TransformStream<I = any, O = any> {
- constructor(
- transformer?: Transformer<I, O>,
- writableStrategy?: QueuingStrategy<I>,
- readableStrategy?: QueuingStrategy<O>,
- );
+declare var WritableStreamDefaultWriter: {
+ prototype: WritableStreamDefaultWriter;
+ new (): WritableStreamDefaultWriter;
+};
+
+interface TransformStream<I = any, O = any> {
readonly readable: ReadableStream<O>;
readonly writable: WritableStream<I>;
}
+declare var TransformStream: {
+ prototype: TransformStream;
+ new <I = any, O = any>(
+ transformer?: Transformer<I, O>,
+ writableStrategy?: QueuingStrategy<I>,
+ readableStrategy?: QueuingStrategy<O>,
+ ): TransformStream<I, O>;
+};
+
interface TransformStreamDefaultController<O = any> {
readonly desiredSize: number | null;
enqueue(chunk: O): void;