diff options
author | David Sherret <dsherret@users.noreply.github.com> | 2020-07-14 15:24:17 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-07-14 15:24:17 -0400 |
commit | cde4dbb35132848ffece59ef9cfaccff32347124 (patch) | |
tree | cc7830968c6decde704c8cfb83c9185193dc698f /cli/js/web/streams/readable_stream.ts | |
parent | 9eca71caa1674c31f9cc5d4e86c03f10b59e0a00 (diff) |
Use dprint for internal formatting (#6682)
Diffstat (limited to 'cli/js/web/streams/readable_stream.ts')
-rw-r--r-- | cli/js/web/streams/readable_stream.ts | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/cli/js/web/streams/readable_stream.ts b/cli/js/web/streams/readable_stream.ts index cf730d23a..086535bd2 100644 --- a/cli/js/web/streams/readable_stream.ts +++ b/cli/js/web/streams/readable_stream.ts @@ -41,10 +41,10 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { underlyingSource: UnderlyingByteSource | UnderlyingSource<R> = {}, strategy: | { - highWaterMark?: number; - size?: undefined; - } - | QueuingStrategy<R> = {} + highWaterMark?: number; + size?: undefined; + } + | QueuingStrategy<R> = {}, ) { initializeReadableStream(this); const { size } = strategy; @@ -54,14 +54,14 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { if (isUnderlyingByteSource(underlyingSource)) { if (size !== undefined) { throw new RangeError( - `When underlying source is "bytes", strategy.size must be undefined.` + `When underlying source is "bytes", strategy.size must be undefined.`, ); } highWaterMark = validateAndNormalizeHighWaterMark(highWaterMark ?? 0); setUpReadableByteStreamControllerFromUnderlyingSource( this, underlyingSource, - highWaterMark + highWaterMark, ); } else if (type === undefined) { const sizeAlgorithm = makeSizeAlgorithmFromSizeFunction(size); @@ -70,11 +70,11 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { this, underlyingSource, highWaterMark, - sizeAlgorithm + sizeAlgorithm, ); } else { throw new RangeError( - `Valid values for underlyingSource are "bytes" or undefined. Received: "${type}".` + `Valid values for underlyingSource are "bytes" or undefined. Received: "${type}".`, ); } } @@ -93,7 +93,7 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { } if (isReadableStreamLocked(this)) { return Promise.reject( - new TypeError("Cannot cancel a locked ReadableStream.") + new TypeError("Cannot cancel a locked ReadableStream."), ); } return readableStreamCancel(this, reason); @@ -132,7 +132,7 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { writable: WritableStream<R>; readable: ReadableStream<T>; }, - { preventClose, preventAbort, preventCancel, signal }: PipeOptions = {} + { preventClose, preventAbort, preventCancel, signal }: PipeOptions = {}, ): ReadableStream<T> { if (!isReadableStream(this)) { throw new TypeError("Invalid ReadableStream."); @@ -161,7 +161,7 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { preventClose, preventAbort, preventCancel, - signal + signal, ); setPromiseIsHandledToTrue(promise); return readable; @@ -169,14 +169,14 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { pipeTo( dest: WritableStream<R>, - { preventClose, preventAbort, preventCancel, signal }: PipeOptions = {} + { preventClose, preventAbort, preventCancel, signal }: PipeOptions = {}, ): Promise<void> { if (!isReadableStream(this)) { return Promise.reject(new TypeError("Invalid ReadableStream.")); } if (!isWritableStream(dest)) { return Promise.reject( - new TypeError("dest is not a valid WritableStream.") + new TypeError("dest is not a valid WritableStream."), ); } preventClose = Boolean(preventClose); @@ -197,7 +197,7 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { preventClose, preventAbort, preventCancel, - signal + signal, ); } @@ -215,7 +215,7 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { [Symbol.asyncIterator]( options: { preventCancel?: boolean; - } = {} + } = {}, ): AsyncIterableIterator<R> { return this.getIterator(options); } |