mirror of
https://github.com/gosticks/DefinitelyTyped.git
synced 2026-10-05 15:27:05 +00:00
desiredSize is null when stream is errored
This commit is contained in:
Vendored
+3
-3
@@ -71,7 +71,7 @@ declare class ReadableStreamBYOBReader<R = ArrayBufferView> {
|
||||
}
|
||||
|
||||
declare class ReadableStreamDefaultController<R = ArrayBufferView> {
|
||||
readonly desiredSize: number;
|
||||
readonly desiredSize: number | null;
|
||||
|
||||
close(): void;
|
||||
enqueue(chunk: R): void;
|
||||
@@ -80,7 +80,7 @@ declare class ReadableStreamDefaultController<R = ArrayBufferView> {
|
||||
|
||||
declare class ReadableByteStreamController<R = ArrayBufferView> {
|
||||
readonly byobRequest: ReadableStreamBYOBRequest<R>;
|
||||
readonly desiredSize: number;
|
||||
readonly desiredSize: number | null;
|
||||
|
||||
close(): void;
|
||||
enqueue(chunk: R): void;
|
||||
@@ -157,5 +157,5 @@ declare class TransformStreamDefaultController<R> {
|
||||
error(reason: any): void;
|
||||
terminate(): void;
|
||||
|
||||
readonly desiredSize: number;
|
||||
readonly desiredSize: number | null;
|
||||
}
|
||||
|
||||
@@ -48,7 +48,7 @@ function makeReadableBackpressureSocketStream(host: string, port: number) {
|
||||
socket.ondata = (event: any) => {
|
||||
controller.enqueue(event.data);
|
||||
|
||||
if (controller.desiredSize <= 0) {
|
||||
if (controller.desiredSize! <= 0) {
|
||||
// The internal queue is full, so propagate
|
||||
// the backpressure signal to the underlying source.
|
||||
socket.readStop();
|
||||
|
||||
Reference in New Issue
Block a user