summaryrefslogtreecommitdiff
path: root/cli/js
diff options
context:
space:
mode:
authorDavid Sherret <dsherret@users.noreply.github.com>2020-07-14 15:24:17 -0400
committerGitHub <noreply@github.com>2020-07-14 15:24:17 -0400
commitcde4dbb35132848ffece59ef9cfaccff32347124 (patch)
treecc7830968c6decde704c8cfb83c9185193dc698f /cli/js
parent9eca71caa1674c31f9cc5d4e86c03f10b59e0a00 (diff)
Use dprint for internal formatting (#6682)
Diffstat (limited to 'cli/js')
-rw-r--r--cli/js/colors.ts2
-rw-r--r--cli/js/compiler.ts115
-rw-r--r--cli/js/compiler_api.ts16
-rw-r--r--cli/js/diagnostics_util.ts46
-rw-r--r--cli/js/error_stack.ts8
-rw-r--r--cli/js/files.ts6
-rw-r--r--cli/js/globals.ts20
-rw-r--r--cli/js/io.ts6
-rw-r--r--cli/js/lib.deno.ns.d.ts63
-rw-r--r--cli/js/lib.deno.shared_globals.d.ts74
-rw-r--r--cli/js/lib.deno.unstable.d.ts28
-rw-r--r--cli/js/lib.deno.worker.d.ts12
-rw-r--r--cli/js/net.ts10
-rw-r--r--cli/js/net_unstable.ts12
-rw-r--r--cli/js/ops/dispatch_minimal.ts8
-rw-r--r--cli/js/ops/fetch.ts2
-rw-r--r--cli/js/ops/fs/chown.ts4
-rw-r--r--cli/js/ops/fs/copy_file.ts4
-rw-r--r--cli/js/ops/fs/mkdir.ts2
-rw-r--r--cli/js/ops/fs/open.ts2
-rw-r--r--cli/js/ops/fs/remove.ts4
-rw-r--r--cli/js/ops/fs/seek.ts4
-rw-r--r--cli/js/ops/fs/symlink.ts4
-rw-r--r--cli/js/ops/fs/utime.ts4
-rw-r--r--cli/js/ops/fs_events.ts2
-rw-r--r--cli/js/ops/get_random_values.ts4
-rw-r--r--cli/js/ops/idna.ts2
-rw-r--r--cli/js/ops/io.ts2
-rw-r--r--cli/js/ops/net.ts4
-rw-r--r--cli/js/ops/runtime_compiler.ts2
-rw-r--r--cli/js/ops/tls.ts2
-rw-r--r--cli/js/ops/worker_host.ts2
-rw-r--r--cli/js/process.ts9
-rw-r--r--cli/js/repl.ts7
-rw-r--r--cli/js/runtime_main.ts2
-rw-r--r--cli/js/runtime_worker.ts6
-rw-r--r--cli/js/signals.ts2
-rw-r--r--cli/js/testing.ts12
-rw-r--r--cli/js/tls.ts2
-rw-r--r--cli/js/util.ts2
-rw-r--r--cli/js/version.ts2
-rw-r--r--cli/js/web/base64.ts20
-rw-r--r--cli/js/web/blob.ts8
-rw-r--r--cli/js/web/body.ts12
-rw-r--r--cli/js/web/console.ts146
-rw-r--r--cli/js/web/console_table.ts12
-rw-r--r--cli/js/web/decode_utf8.ts20
-rw-r--r--cli/js/web/dom_file.ts2
-rw-r--r--cli/js/web/dom_iterable.ts10
-rw-r--r--cli/js/web/dom_types.d.ts4
-rw-r--r--cli/js/web/error_event.ts2
-rw-r--r--cli/js/web/event.ts8
-rw-r--r--cli/js/web/event_target.ts42
-rw-r--r--cli/js/web/fetch.ts22
-rw-r--r--cli/js/web/fetch/multipart.ts4
-rw-r--r--cli/js/web/form_data.ts6
-rw-r--r--cli/js/web/headers.ts10
-rw-r--r--cli/js/web/performance.ts50
-rw-r--r--cli/js/web/streams/internals.ts398
-rw-r--r--cli/js/web/streams/queuing_strategy.ts12
-rw-r--r--cli/js/web/streams/readable_byte_stream_controller.ts20
-rw-r--r--cli/js/web/streams/readable_stream.ts30
-rw-r--r--cli/js/web/streams/readable_stream_async_iterator.ts31
-rw-r--r--cli/js/web/streams/readable_stream_default_controller.ts16
-rw-r--r--cli/js/web/streams/readable_stream_default_reader.ts8
-rw-r--r--cli/js/web/streams/symbols.ts2
-rw-r--r--cli/js/web/streams/transform_stream.ts32
-rw-r--r--cli/js/web/streams/transform_stream_default_controller.ts12
-rw-r--r--cli/js/web/streams/writable_stream.ts10
-rw-r--r--cli/js/web/streams/writable_stream_default_controller.ts4
-rw-r--r--cli/js/web/streams/writable_stream_default_writer.ts24
-rw-r--r--cli/js/web/text_encoding.ts14
-rw-r--r--cli/js/web/timers.ts6
-rw-r--r--cli/js/web/url.ts42
-rw-r--r--cli/js/web/url_search_params.ts8
-rw-r--r--cli/js/web/util.ts16
-rw-r--r--cli/js/web/workers.ts6
-rw-r--r--cli/js/write_file.ts4
-rw-r--r--cli/js/write_text_file.ts4
79 files changed, 796 insertions, 801 deletions
diff --git a/cli/js/colors.ts b/cli/js/colors.ts
index eccb3567a..b98611bfa 100644
--- a/cli/js/colors.ts
+++ b/cli/js/colors.ts
@@ -70,7 +70,7 @@ const ANSI_PATTERN = new RegExp(
"[\\u001B\\u009B][[\\]()#;?]*(?:(?:(?:[a-zA-Z\\d]*(?:;[-a-zA-Z\\d\\/#&.:=?%@~_]*)*)?\\u0007)",
"(?:(?:\\d{1,4}(?:;\\d{0,4})*)?[\\dA-PR-TZcf-ntqry=><~]))",
].join("|"),
- "g"
+ "g",
);
export function stripColor(string: string): string {
diff --git a/cli/js/compiler.ts b/cli/js/compiler.ts
index fc75a7c10..7a56fe209 100644
--- a/cli/js/compiler.ts
+++ b/cli/js/compiler.ts
@@ -182,13 +182,15 @@ interface CompilerHostOptions {
incremental?: boolean;
}
-type IncrementalCompilerHostOptions = Omit<
- CompilerHostOptions,
- "incremental"
-> & {
- rootNames?: string[];
- buildInfo?: string;
-};
+type IncrementalCompilerHostOptions =
+ & Omit<
+ CompilerHostOptions,
+ "incremental"
+ >
+ & {
+ rootNames?: string[];
+ buildInfo?: string;
+ };
interface HostConfigureResponse {
ignoredOptions?: string[];
@@ -235,7 +237,9 @@ function getExtension(fileName: string, mediaType: MediaType): ts.Extension {
case MediaType.Unknown:
default:
throw TypeError(
- `Cannot resolve extension for "${fileName}" with mediaType "${MediaType[mediaType]}".`
+ `Cannot resolve extension for "${fileName}" with mediaType "${
+ MediaType[mediaType]
+ }".`,
);
}
}
@@ -259,7 +263,7 @@ function configure(
defaultOptions: ts.CompilerOptions,
source: string,
path: string,
- cwd: string
+ cwd: string,
): ConfigureResponse {
const { config, error } = ts.parseConfigFileTextToJson(path, source);
if (error) {
@@ -267,7 +271,7 @@ function configure(
}
const { options, errors } = ts.convertCompilerOptionsFromJson(
config.compilerOptions,
- cwd
+ cwd,
);
const ignoredOptions: string[] = [];
for (const key of Object.keys(options)) {
@@ -318,7 +322,7 @@ class SourceFile {
static cacheResolvedUrl(
resolvedUrl: string,
rawModuleSpecifier: string,
- containingFile?: string
+ containingFile?: string,
): void {
containingFile = containingFile || "";
let innerCache = RESOLVED_SPECIFIER_CACHE.get(containingFile);
@@ -331,7 +335,7 @@ class SourceFile {
static getResolvedUrl(
moduleSpecifier: string,
- containingFile: string
+ containingFile: string,
): string | undefined {
const containingCache = RESOLVED_SPECIFIER_CACHE.get(containingFile);
if (containingCache) {
@@ -399,14 +403,14 @@ class Host implements ts.CompilerHost {
configure(
cwd: string,
path: string,
- configurationText: string
+ configurationText: string,
): HostConfigureResponse {
log("compiler::host.configure", path);
const { options, ...result } = configure(
this.#options,
configurationText,
path,
- cwd
+ cwd,
);
this.#options = options;
return result;
@@ -455,7 +459,7 @@ class Host implements ts.CompilerHost {
fileName: string,
languageVersion: ts.ScriptTarget,
onError?: (message: string) => void,
- shouldCreateNewSourceFile?: boolean
+ shouldCreateNewSourceFile?: boolean,
): ts.SourceFile | undefined {
log("compiler::host.getSourceFile", fileName);
try {
@@ -473,7 +477,7 @@ class Host implements ts.CompilerHost {
sourceFile.tsSourceFile = ts.createSourceFile(
tsSourceFileName,
sourceFile.sourceCode,
- languageVersion
+ languageVersion,
);
sourceFile.tsSourceFile.version = sourceFile.versionHash;
delete sourceFile.sourceCode;
@@ -495,7 +499,7 @@ class Host implements ts.CompilerHost {
resolveModuleNames(
moduleNames: string[],
- containingFile: string
+ containingFile: string,
): Array<ts.ResolvedModuleFull | undefined> {
log("compiler::host.resolveModuleNames", {
moduleNames,
@@ -540,7 +544,7 @@ class Host implements ts.CompilerHost {
data: string,
_writeByteOrderMark: boolean,
_onError?: (message: string) => void,
- sourceFiles?: readonly ts.SourceFile[]
+ sourceFiles?: readonly ts.SourceFile[],
): void {
log("compiler::host.writeFile", fileName);
this.#writeFile(fileName, data, sourceFiles);
@@ -588,23 +592,23 @@ ts.libMap.set("deno.unstable", "lib.deno.unstable.d.ts");
// are available in the future when needed.
SNAPSHOT_HOST.getSourceFile(
`${ASSETS}/lib.deno.ns.d.ts`,
- ts.ScriptTarget.ESNext
+ ts.ScriptTarget.ESNext,
);
SNAPSHOT_HOST.getSourceFile(
`${ASSETS}/lib.deno.window.d.ts`,
- ts.ScriptTarget.ESNext
+ ts.ScriptTarget.ESNext,
);
SNAPSHOT_HOST.getSourceFile(
`${ASSETS}/lib.deno.worker.d.ts`,
- ts.ScriptTarget.ESNext
+ ts.ScriptTarget.ESNext,
);
SNAPSHOT_HOST.getSourceFile(
`${ASSETS}/lib.deno.shared_globals.d.ts`,
- ts.ScriptTarget.ESNext
+ ts.ScriptTarget.ESNext,
);
SNAPSHOT_HOST.getSourceFile(
`${ASSETS}/lib.deno.unstable.d.ts`,
- ts.ScriptTarget.ESNext
+ ts.ScriptTarget.ESNext,
);
// We never use this program; it's only created
@@ -624,7 +628,7 @@ const SYSTEM_LOADER = getAsset("system_loader.js");
const SYSTEM_LOADER_ES5 = getAsset("system_loader_es5.js");
function buildLocalSourceFileCache(
- sourceFileMap: Record<string, SourceFileMapEntry>
+ sourceFileMap: Record<string, SourceFileMapEntry>,
): void {
for (const entry of Object.values(sourceFileMap)) {
assert(entry.sourceCode.length > 0);
@@ -640,8 +644,7 @@ function buildLocalSourceFileCache(
let mappedUrl = importDesc.resolvedSpecifier;
const importedFile = sourceFileMap[importDesc.resolvedSpecifier];
assert(importedFile);
- const isJsOrJsx =
- importedFile.mediaType === MediaType.JavaScript ||
+ const isJsOrJsx = importedFile.mediaType === MediaType.JavaScript ||
importedFile.mediaType === MediaType.JSX;
// If JS or JSX perform substitution for types if available
if (isJsOrJsx) {
@@ -663,21 +666,21 @@ function buildLocalSourceFileCache(
SourceFile.cacheResolvedUrl(
fileRef.resolvedSpecifier.replace("memory://", ""),
fileRef.specifier,
- entry.url
+ entry.url,
);
}
for (const fileRef of entry.libDirectives) {
SourceFile.cacheResolvedUrl(
fileRef.resolvedSpecifier.replace("memory://", ""),
fileRef.specifier,
- entry.url
+ entry.url,
);
}
}
}
function buildSourceFileCache(
- sourceFileMap: Record<string, SourceFileMapEntry>
+ sourceFileMap: Record<string, SourceFileMapEntry>,
): void {
for (const entry of Object.values(sourceFileMap)) {
SourceFile.addToCache({
@@ -700,8 +703,7 @@ function buildSourceFileCache(
if (importedFile.redirect) {
mappedUrl = importedFile.redirect;
}
- const isJsOrJsx =
- importedFile.mediaType === MediaType.JavaScript ||
+ const isJsOrJsx = importedFile.mediaType === MediaType.JavaScript ||
importedFile.mediaType === MediaType.JSX;
// If JS or JSX perform substitution for types if available
if (isJsOrJsx) {
@@ -722,14 +724,14 @@ function buildSourceFileCache(
SourceFile.cacheResolvedUrl(
fileRef.resolvedSpecifier,
fileRef.specifier,
- entry.url
+ entry.url,
);
}
for (const fileRef of entry.libDirectives) {
SourceFile.cacheResolvedUrl(
fileRef.resolvedSpecifier,
fileRef.specifier,
- entry.url
+ entry.url,
);
}
}
@@ -745,7 +747,7 @@ interface EmittedSource {
type WriteFileCallback = (
fileName: string,
data: string,
- sourceFiles?: readonly ts.SourceFile[]
+ sourceFiles?: readonly ts.SourceFile[],
) => void;
interface CompileWriteFileState {
@@ -775,7 +777,7 @@ function createBundleWriteFile(state: BundleWriteFileState): WriteFileCallback {
return function writeFile(
_fileName: string,
data: string,
- sourceFiles?: readonly ts.SourceFile[]
+ sourceFiles?: readonly ts.SourceFile[],
): void {
assert(sourceFiles != null);
assert(state.host);
@@ -785,18 +787,18 @@ function createBundleWriteFile(state: BundleWriteFileState): WriteFileCallback {
state.rootNames[0],
data,
sourceFiles,
- state.host.options.target ?? ts.ScriptTarget.ESNext
+ state.host.options.target ?? ts.ScriptTarget.ESNext,
);
};
}
function createCompileWriteFile(
- state: CompileWriteFileState
+ state: CompileWriteFileState,
): WriteFileCallback {
return function writeFile(
fileName: string,
data: string,
- sourceFiles?: readonly ts.SourceFile[]
+ sourceFiles?: readonly ts.SourceFile[],
): void {
const isBuildInfo = fileName === TS_BUILD_INFO;
@@ -816,12 +818,12 @@ function createCompileWriteFile(
}
function createRuntimeCompileWriteFile(
- state: CompileWriteFileState
+ state: CompileWriteFileState,
): WriteFileCallback {
return function writeFile(
fileName: string,
data: string,
- sourceFiles?: readonly ts.SourceFile[]
+ sourceFiles?: readonly ts.SourceFile[],
): void {
assert(sourceFiles);
assert(sourceFiles.length === 1);
@@ -1020,14 +1022,14 @@ function performanceEnd(): Stats {
// TODO(Bartlomieju): this check should be done in Rust; there should be no
function processConfigureResponse(
configResult: HostConfigureResponse,
- configPath: string
+ configPath: string,
): ts.Diagnostic[] | undefined {
const { ignoredOptions, diagnostics } = configResult;
if (ignoredOptions) {
console.warn(
yellow(`Unsupported compiler options in "${configPath}"\n`) +
cyan(` The following options were ignored:\n`) +
- ` ${ignoredOptions.map((value): string => bold(value)).join(", ")}`
+ ` ${ignoredOptions.map((value): string => bold(value)).join(", ")}`,
);
}
return diagnostics;
@@ -1130,7 +1132,7 @@ function buildBundle(
rootName: string,
data: string,
sourceFiles: readonly ts.SourceFile[],
- target: ts.ScriptTarget
+ target: ts.ScriptTarget,
): string {
// when outputting to AMD and a single outfile, TypeScript makes up the module
// specifiers which are used to define the modules, and doesn't expose them
@@ -1162,8 +1164,7 @@ function buildBundle(
? `await __instantiate("${rootName}", true);\n`
: `__instantiate("${rootName}", false);\n`;
}
- const es5Bundle =
- target === ts.ScriptTarget.ES3 ||
+ const es5Bundle = target === ts.ScriptTarget.ES3 ||
target === ts.ScriptTarget.ES5 ||
target === ts.ScriptTarget.ES2015 ||
target === ts.ScriptTarget.ES2016;
@@ -1205,7 +1206,7 @@ function setRootExports(program: ts.Program, rootModule: string): void {
sym.flags & ts.SymbolFlags.InterfaceExcludes ||
sym.flags & ts.SymbolFlags.TypeParameterExcludes ||
sym.flags & ts.SymbolFlags.TypeAliasExcludes
- )
+ ),
)
.map((sym) => sym.getName());
}
@@ -1408,7 +1409,7 @@ function compile({
...program.getSemanticDiagnostics(),
];
diagnostics = diagnostics.filter(
- ({ code }) => !ignoredDiagnostics.includes(code)
+ ({ code }) => !ignoredDiagnostics.includes(code),
);
// We will only proceed with the emit if there are no diagnostics.
@@ -1420,7 +1421,7 @@ function compile({
if (options.checkJs) {
assert(
emitResult.emitSkipped === false,
- "Unexpected skip of the emit."
+ "Unexpected skip of the emit.",
);
}
// emitResult.diagnostics is `readonly` in TS3.5+ and can't be assigned
@@ -1458,7 +1459,7 @@ function transpile({
DEFAULT_TRANSPILE_OPTIONS,
configText,
configPath,
- cwd
+ cwd,
);
const diagnostics = processConfigureResponse(response, configPath);
if (diagnostics && diagnostics.length) {
@@ -1598,7 +1599,7 @@ function bundle({
}
function runtimeCompile(
- request: RuntimeCompileRequest
+ request: RuntimeCompileRequest,
): RuntimeCompileResponse {
const { options, rootNames, target, unstable, sourceFileMap } = request;
@@ -1742,16 +1743,16 @@ function runtimeBundle(request: RuntimeBundleRequest): RuntimeBundleResponse {
}
function runtimeTranspile(
- request: RuntimeTranspileRequest
+ request: RuntimeTranspileRequest,
): Promise<Record<string, TranspileOnlyResult>> {
const result: Record<string, TranspileOnlyResult> = {};
const { sources, options } = request;
const compilerOptions = options
? Object.assign(
- {},
- DEFAULT_RUNTIME_TRANSPILE_OPTIONS,
- convertCompilerOptions(options).options
- )
+ {},
+ DEFAULT_RUNTIME_TRANSPILE_OPTIONS,
+ convertCompilerOptions(options).options,
+ )
: DEFAULT_RUNTIME_TRANSPILE_OPTIONS;
for (const [fileName, inputText] of Object.entries(sources)) {
@@ -1760,7 +1761,7 @@ function runtimeTranspile(
{
fileName,
compilerOptions,
- }
+ },
);
result[fileName] = { source, map };
}
@@ -1807,7 +1808,7 @@ async function tsCompilerOnMessage({
log(
`!!! unhandled CompilerRequestType: ${
(request as CompilerRequest).type
- } (${CompilerRequestType[(request as CompilerRequest).type]})`
+ } (${CompilerRequestType[(request as CompilerRequest).type]})`,
);
}
// Shutdown after single request
diff --git a/cli/js/compiler_api.ts b/cli/js/compiler_api.ts
index 8a50e0b3d..e0488b7f6 100644
--- a/cli/js/compiler_api.ts
+++ b/cli/js/compiler_api.ts
@@ -18,7 +18,7 @@ function checkRelative(specifier: string): string {
// TODO(bartlomieju): change return type to interface?
export function transpileOnly(
sources: Record<string, string>,
- options: CompilerOptions = {}
+ options: CompilerOptions = {},
): Promise<Record<string, TranspileOnlyResult>> {
util.log("Deno.transpileOnly", { sources: Object.keys(sources), options });
const payload = {
@@ -32,7 +32,7 @@ export function transpileOnly(
export async function compile(
rootName: string,
sources?: Record<string, string>,
- options: CompilerOptions = {}
+ options: CompilerOptions = {},
): Promise<[DiagnosticItem[] | undefined, Record<string, string>]> {
const payload = {
rootName: sources ? rootName : checkRelative(rootName),
@@ -47,8 +47,9 @@ export async function compile(
});
const result = await runtimeCompilerOps.compile(payload);
util.assert(result.emitMap);
- const maybeDiagnostics =
- result.diagnostics.length === 0 ? undefined : result.diagnostics;
+ const maybeDiagnostics = result.diagnostics.length === 0
+ ? undefined
+ : result.diagnostics;
const emitMap: Record<string, string> = {};
@@ -63,7 +64,7 @@ export async function compile(
export async function bundle(
rootName: string,
sources?: Record<string, string>,
- options: CompilerOptions = {}
+ options: CompilerOptions = {},
): Promise<[DiagnosticItem[] | undefined, string]> {
const payload = {
rootName: sources ? rootName : checkRelative(rootName),
@@ -78,7 +79,8 @@ export async function bundle(
});
const result = await runtimeCompilerOps.compile(payload);
util.assert(result.output);
- const maybeDiagnostics =
- result.diagnostics.length === 0 ? undefined : result.diagnostics;
+ const maybeDiagnostics = result.diagnostics.length === 0
+ ? undefined
+ : result.diagnostics;
return [maybeDiagnostics, result.output];
}
diff --git a/cli/js/diagnostics_util.ts b/cli/js/diagnostics_util.ts
index 3e0bfde27..fc2684baf 100644
--- a/cli/js/diagnostics_util.ts
+++ b/cli/js/diagnostics_util.ts
@@ -91,7 +91,7 @@ function transformMessageText(messageText: string, code: number): string {
const suggestion = messageText.match(suggestionMessagePattern);
const replacedMessageText = messageText.replace(
suggestionMessagePattern,
- ""
+ "",
);
if (suggestion && unstableDenoGlobalProperties.includes(property)) {
const suggestedProperty = suggestion[1];
@@ -113,7 +113,7 @@ interface SourceInformation {
}
function fromDiagnosticCategory(
- category: ts.DiagnosticCategory
+ category: ts.DiagnosticCategory,
): DiagnosticCategory {
switch (category) {
case ts.DiagnosticCategory.Error:
@@ -126,7 +126,9 @@ function fromDiagnosticCategory(
return DiagnosticCategory.Warning;
default:
throw new Error(
- `Unexpected DiagnosticCategory: "${category}"/"${ts.DiagnosticCategory[category]}"`
+ `Unexpected DiagnosticCategory: "${category}"/"${
+ ts.DiagnosticCategory[category]
+ }"`,
);
}
}
@@ -134,7 +136,7 @@ function fromDiagnosticCategory(
function getSourceInformation(
sourceFile: ts.SourceFile,
start: number,
- length: number
+ length: number,
): SourceInformation {
const scriptResourceName = sourceFile.fileName;
const {
@@ -142,16 +144,16 @@ function getSourceInformation(
character: startColumn,
} = sourceFile.getLineAndCharacterOfPosition(start);
const endPosition = sourceFile.getLineAndCharacterOfPosition(start + length);
- const endColumn =
- lineNumber === endPosition.line ? endPosition.character : startColumn;
+ const endColumn = lineNumber === endPosition.line
+ ? endPosition.character
+ : startColumn;
const lastLineInFile = sourceFile.getLineAndCharacterOfPosition(
- sourceFile.text.length
+ sourceFile.text.length,
).line;
const lineStart = sourceFile.getPositionOfLineAndCharacter(lineNumber, 0);
- const lineEnd =
- lineNumber < lastLineInFile
- ? sourceFile.getPositionOfLineAndCharacter(lineNumber + 1, 0)
- : sourceFile.text.length;
+ const lineEnd = lineNumber < lastLineInFile
+ ? sourceFile.getPositionOfLineAndCharacter(lineNumber + 1, 0)
+ : sourceFile.text.length;
const sourceLine = sourceFile.text
.slice(lineStart, lineEnd)
.replace(/\s+$/g, "")
@@ -166,7 +168,7 @@ function getSourceInformation(
}
function fromDiagnosticMessageChain(
- messageChain: ts.DiagnosticMessageChain[] | undefined
+ messageChain: ts.DiagnosticMessageChain[] | undefined,
): DiagnosticMessageChain[] | undefined {
if (!messageChain) {
return undefined;
@@ -184,7 +186,7 @@ function fromDiagnosticMessageChain(
}
function parseDiagnostic(
- item: ts.Diagnostic | ts.DiagnosticRelatedInformation
+ item: ts.Diagnostic | ts.DiagnosticRelatedInformation,
): DiagnosticItem {
const {
messageText,
@@ -194,12 +196,12 @@ function parseDiagnostic(
start: startPosition,
length,
} = item;
- const sourceInfo =
- file && startPosition && length
- ? getSourceInformation(file, startPosition, length)
- : undefined;
- const endPosition =
- startPosition && length ? startPosition + length : undefined;
+ const sourceInfo = file && startPosition && length
+ ? getSourceInformation(file, startPosition, length)
+ : undefined;
+ const endPosition = startPosition && length
+ ? startPosition + length
+ : undefined;
const category = fromDiagnosticCategory(sourceCategory);
let message: string;
@@ -224,7 +226,7 @@ function parseDiagnostic(
}
function parseRelatedInformation(
- relatedInformation: readonly ts.DiagnosticRelatedInformation[]
+ relatedInformation: readonly ts.DiagnosticRelatedInformation[],
): DiagnosticItem[] {
const result: DiagnosticItem[] = [];
for (const item of relatedInformation) {
@@ -234,14 +236,14 @@ function parseRelatedInformation(
}
export function fromTypeScriptDiagnostic(
- diagnostics: readonly ts.Diagnostic[]
+ diagnostics: readonly ts.Diagnostic[],
): Diagnostic {
const items: DiagnosticItem[] = [];
for (const sourceDiagnostic of diagnostics) {
const item: DiagnosticItem = parseDiagnostic(sourceDiagnostic);
if (sourceDiagnostic.relatedInformation) {
item.relatedInformation = parseRelatedInformation(
- sourceDiagnostic.relatedInformation
+ sourceDiagnostic.relatedInformation,
);
}
items.push(item);
diff --git a/cli/js/error_stack.ts b/cli/js/error_stack.ts
index 4c46675ca..97ce00f3a 100644
--- a/cli/js/error_stack.ts
+++ b/cli/js/error_stack.ts
@@ -149,7 +149,7 @@ function callSiteToString(callSite: CallSite, internal = false): string {
}
if (isPromiseAll) {
result += colors.bold(
- colors.italic(black(`Promise.all (index ${callSite.getPromiseIndex()})`))
+ colors.italic(black(`Promise.all (index ${callSite.getPromiseIndex()})`)),
);
return result;
}
@@ -218,7 +218,7 @@ function prepareStackTrace(
__callSiteEvals: CallSiteEval[];
__formattedFrames: string[];
},
- callSites: CallSite[]
+ callSites: CallSite[],
): string {
const mappedCallSites = callSites.map(
(callSite): CallSite => {
@@ -232,11 +232,11 @@ function prepareStackTrace(
fileName,
lineNumber,
columnNumber,
- })
+ }),
);
}
return callSite;
- }
+ },
);
Object.defineProperties(error, {
__callSiteEvals: { value: [], configurable: true },
diff --git a/cli/js/files.ts b/cli/js/files.ts
index 3afcb4878..e9f12a489 100644
--- a/cli/js/files.ts
+++ b/cli/js/files.ts
@@ -23,7 +23,7 @@ export type { OpenOptions } from "./ops/fs/open.ts";
export function openSync(
path: string | URL,
- options: OpenOptions = { read: true }
+ options: OpenOptions = { read: true },
): File {
checkOpenOptions(options);
const rid = opOpenSync(path, options);
@@ -32,7 +32,7 @@ export function openSync(
export async function open(
path: string | URL,
- options: OpenOptions = { read: true }
+ options: OpenOptions = { read: true },
): Promise<File> {
checkOpenOptions(options);
const rid = await opOpen(path, options);
@@ -163,7 +163,7 @@ function checkOpenOptions(options: OpenOptions): void {
if (createOrCreateNewWithoutWriteOrAppend) {
throw new Error(
- "'create' or 'createNew' options require 'write' or 'append' option"
+ "'create' or 'createNew' options require 'write' or 'append' option",
);
}
}
diff --git a/cli/js/globals.ts b/cli/js/globals.ts
index ff2ff8f4d..aa826f63a 100644
--- a/cli/js/globals.ts
+++ b/cli/js/globals.ts
@@ -104,7 +104,7 @@ declare global {
evalContext(
code: string,
- scriptName?: string
+ scriptName?: string,
): [unknown, EvalErrorInfo | null];
formatError: (e: Error) => string;
@@ -150,12 +150,12 @@ declare global {
var onerror:
| ((
- msg: string,
- source: string,
- lineno: number,
- colno: number,
- e: Event
- ) => boolean | void)
+ msg: string,
+ source: string,
+ lineno: number,
+ colno: number,
+ e: Event,
+ ) => boolean | void)
| undefined;
// eslint-disable-next-line @typescript-eslint/no-explicit-any
@@ -218,7 +218,7 @@ export const windowOrWorkerGlobalScopeProperties = {
AbortSignal: nonEnumerable(abortSignal.AbortSignalImpl),
Blob: nonEnumerable(blob.DenoBlob),
ByteLengthQueuingStrategy: nonEnumerable(
- queuingStrategy.ByteLengthQueuingStrategyImpl
+ queuingStrategy.ByteLengthQueuingStrategyImpl,
),
CountQueuingStrategy: nonEnumerable(queuingStrategy.CountQueuingStrategyImpl),
crypto: readOnly(csprng),
@@ -254,10 +254,10 @@ export function setEventTargetData(value: any): void {
export const eventTargetProperties = {
addEventListener: readOnly(
- eventTarget.EventTargetImpl.prototype.addEventListener
+ eventTarget.EventTargetImpl.prototype.addEventListener,
),
dispatchEvent: readOnly(eventTarget.EventTargetImpl.prototype.dispatchEvent),
removeEventListener: readOnly(
- eventTarget.EventTargetImpl.prototype.removeEventListener
+ eventTarget.EventTargetImpl.prototype.removeEventListener,
),
};
diff --git a/cli/js/io.ts b/cli/js/io.ts
index 2686fd3cb..b2e6499b8 100644
--- a/cli/js/io.ts
+++ b/cli/js/io.ts
@@ -55,7 +55,7 @@ export async function copy(
dst: Writer,
options?: {
bufSize?: number;
- }
+ },
): Promise<number> {
let n = 0;
const bufSize = options?.bufSize ?? DEFAULT_BUFFER_SIZE;
@@ -80,7 +80,7 @@ export async function* iter(
r: Reader,
options?: {
bufSize?: number;
- }
+ },
): AsyncIterableIterator<Uint8Array> {
const bufSize = options?.bufSize ?? DEFAULT_BUFFER_SIZE;
const b = new Uint8Array(bufSize);
@@ -98,7 +98,7 @@ export function* iterSync(
r: ReaderSync,
options?: {
bufSize?: number;
- }
+ },
): IterableIterator<Uint8Array> {
const bufSize = options?.bufSize ?? DEFAULT_BUFFER_SIZE;
const b = new Uint8Array(bufSize);
diff --git a/cli/js/lib.deno.ns.d.ts b/cli/js/lib.deno.ns.d.ts
index 47402187d..962179381 100644
--- a/cli/js/lib.deno.ns.d.ts
+++ b/cli/js/lib.deno.ns.d.ts
@@ -34,7 +34,7 @@ declare interface Performance {
* associated name (a "measure"). */
measure(
measureName: string,
- options?: PerformanceMeasureOptions
+ options?: PerformanceMeasureOptions,
): PerformanceMeasure;
}
@@ -394,7 +394,7 @@ declare namespace Deno {
dst: Writer,
options?: {
bufSize?: number;
- }
+ },
): Promise<number>;
/** Turns a Reader, `r`, into an async iterator.
@@ -430,7 +430,7 @@ declare namespace Deno {
r: Reader,
options?: {
bufSize?: number;
- }
+ },
): AsyncIterableIterator<Uint8Array>;
/** Turns a ReaderSync, `r`, into an iterator.
@@ -466,7 +466,7 @@ declare namespace Deno {
r: ReaderSync,
options?: {
bufSize?: number;
- }
+ },
): IterableIterator<Uint8Array>;
/** Synchronously open a file and return an instance of `Deno.File`. The
@@ -499,7 +499,7 @@ declare namespace Deno {
*/
export function open(
path: string | URL,
- options?: OpenOptions
+ options?: OpenOptions,
): Promise<File>;
/** Creates a file if none exists or truncates an existing file and returns
@@ -641,7 +641,7 @@ declare namespace Deno {
export function seekSync(
rid: number,
offset: number,
- whence: SeekMode
+ whence: SeekMode,
): number;
/** Seek a resource ID (`rid`) to the given `offset` under mode given by `whence`.
@@ -673,7 +673,7 @@ declare namespace Deno {
export function seek(
rid: number,
offset: number,
- whence: SeekMode
+ whence: SeekMode,
): Promise<number>;
/** Close the given resource ID (rid) which has been previously opened, such
@@ -973,7 +973,7 @@ declare namespace Deno {
* Requires `allow-write` permission. */
export function mkdir(
path: string | URL,
- options?: MkdirOptions
+ options?: MkdirOptions,
): Promise<void>;
export interface MakeTempOptions {
@@ -1132,7 +1132,7 @@ declare namespace Deno {
export function chownSync(
path: string | URL,
uid: number | null,
- gid: number | null
+ gid: number | null,
): void;
/** Change owner of a regular file or directory. This functionality
@@ -1153,7 +1153,7 @@ declare namespace Deno {
export function chown(
path: string | URL,
uid: number | null,
- gid: number | null
+ gid: number | null,
): Promise<void>;
export interface RemoveOptions {
@@ -1188,7 +1188,7 @@ declare namespace Deno {
* Requires `allow-write` permission. */
export function remove(
path: string | URL,
- options?: RemoveOptions
+ options?: RemoveOptions,
): Promise<void>;
/** Synchronously renames (moves) `oldpath` to `newpath`. Paths may be files or
@@ -1417,7 +1417,7 @@ declare namespace Deno {
* Requires `allow-write` permission on toPath. */
export function copyFileSync(
fromPath: string | URL,
- toPath: string | URL
+ toPath: string | URL,
): void;
/** Copies the contents and permissions of one file to another specified path,
@@ -1432,7 +1432,7 @@ declare namespace Deno {
* Requires `allow-write` permission on toPath. */
export function copyFile(
fromPath: string | URL,
- toPath: string | URL
+ toPath: string | URL,
): Promise<void>;
/** Returns the full path destination of the named symbolic link.
@@ -1538,7 +1538,7 @@ declare namespace Deno {
export function writeFileSync(
path: string | URL,
data: Uint8Array,
- options?: WriteFileOptions
+ options?: WriteFileOptions,
): void;
/** Write `data` to the given `path`, by default creating a new file if needed,
@@ -1558,7 +1558,7 @@ declare namespace Deno {
export function writeFile(
path: string | URL,
data: Uint8Array,
- options?: WriteFileOptions
+ options?: WriteFileOptions,
): Promise<void>;
/** Synchronously write string `data` to the given `path`, by default creating a new file if needed,
@@ -1573,7 +1573,7 @@ declare namespace Deno {
export function writeTextFileSync(
path: string | URL,
data: string,
- options?: WriteFileOptions
+ options?: WriteFileOptions,
): void;
/** Asynchronously write string `data` to the given `path`, by default creating a new file if needed,
@@ -1588,7 +1588,7 @@ declare namespace Deno {
export function writeTextFile(
path: string | URL,
data: string,
- options?: WriteFileOptions
+ options?: WriteFileOptions,
): Promise<void>;
/** Synchronously truncates or extends the specified file, to reach the
@@ -1692,7 +1692,7 @@ declare namespace Deno {
*
* Requires `allow-net` permission. */
export function listen(
- options: ListenOptions & { transport?: "tcp" }
+ options: ListenOptions & { transport?: "tcp" },
): Listener;
export interface ListenTlsOptions extends ListenOptions {
@@ -1844,20 +1844,17 @@ declare namespace Deno {
*/
export function watchFs(
paths: string | string[],
- options?: { recursive: boolean }
+ options?: { recursive: boolean },
): AsyncIterableIterator<FsEvent>;
export class Process<T extends RunOptions = RunOptions> {
readonly rid: number;
readonly pid: number;
- readonly stdin: T["stdin"] extends "piped"
- ? Writer & Closer
+ readonly stdin: T["stdin"] extends "piped" ? Writer & Closer
: (Writer & Closer) | null;
- readonly stdout: T["stdout"] extends "piped"
- ? Reader & Closer
+ readonly stdout: T["stdout"] extends "piped" ? Reader & Closer
: (Reader & Closer) | null;
- readonly stderr: T["stderr"] extends "piped"
- ? Reader & Closer
+ readonly stderr: T["stderr"] extends "piped" ? Reader & Closer
: (Reader & Closer) | null;
/** Resolves to the current status of the process. */
status(): Promise<ProcessStatus>;
@@ -1886,15 +1883,15 @@ declare namespace Deno {
export type ProcessStatus =
| {
- success: true;
- code: 0;
- signal?: undefined;
- }
+ success: true;
+ code: 0;
+ signal?: undefined;
+ }
| {
- success: false;
- code: number;
- signal?: number;
- };
+ success: false;
+ code: number;
+ signal?: number;
+ };
export interface RunOptions {
/** Arguments to pass. Note, the first element needs to be a path to the
diff --git a/cli/js/lib.deno.shared_globals.d.ts b/cli/js/lib.deno.shared_globals.d.ts
index f37dfa366..c77f1ea0e 100644
--- a/cli/js/lib.deno.shared_globals.d.ts
+++ b/cli/js/lib.deno.shared_globals.d.ts
@@ -31,7 +31,7 @@ declare namespace WebAssembly {
* its first `WebAssembly.Instance`. */
function instantiate(
bufferSource: BufferSource,
- importObject?: object
+ importObject?: object,
): Promise<WebAssemblyInstantiatedSource>;
/** Takes an already-compiled `WebAssembly.Module` and returns a `Promise`
@@ -39,7 +39,7 @@ declare namespace WebAssembly {
* the `Module` has already been compiled. */
function instantiate(
module: Module,
- importObject?: object
+ importObject?: object,
): Promise<Instance>;
/** Compiles and instantiates a WebAssembly module directly from a streamed
@@ -47,7 +47,7 @@ declare namespace WebAssembly {
* code. */
function instantiateStreaming(
source: Promise<Response>,
- importObject?: object
+ importObject?: object,
): Promise<WebAssemblyInstantiatedSource>;
/** Validates a given typed array of WebAssembly binary code, returning
@@ -73,7 +73,7 @@ declare namespace WebAssembly {
* custom sections in the module with the given string name. */
static customSections(
moduleObject: Module,
- sectionName: string
+ sectionName: string,
): ArrayBuffer;
/** Given a `Module`, returns an array containing descriptions of all the
@@ -246,7 +246,7 @@ declare var crypto: Crypto;
declare function addEventListener(
type: string,
callback: EventListenerOrEventListenerObject | null,
- options?: boolean | AddEventListenerOptions | undefined
+ options?: boolean | AddEventListenerOptions | undefined,
): void;
/** Dispatches an event in the global scope, synchronously invoking any
@@ -267,7 +267,7 @@ declare function dispatchEvent(event: Event): boolean;
declare function removeEventListener(
type: string,
callback: EventListenerOrEventListenerObject | null,
- options?: boolean | EventListenerOptions | undefined
+ options?: boolean | EventListenerOptions | undefined,
): void;
interface DomIterable<K, V> {
@@ -277,7 +277,7 @@ interface DomIterable<K, V> {
[Symbol.iterator](): IterableIterator<[K, V]>;
forEach(
callback: (value: V, key: K, parent: this) => void,
- thisArg?: any
+ thisArg?: any,
): void;
}
@@ -398,7 +398,7 @@ interface ReadableStream<R = any> {
writable: WritableStream<R>;
readable: ReadableStream<T>;
},
- options?: PipeOptions
+ options?: PipeOptions,
): ReadableStream<T>;
pipeTo(dest: WritableStream<R>, options?: PipeOptions): Promise<void>;
tee(): [ReadableStream<R>, ReadableStream<R>];
@@ -411,11 +411,11 @@ declare var ReadableStream: {
prototype: ReadableStream;
new (
underlyingSource: UnderlyingByteSource,
- strategy?: { highWaterMark?: number; size?: undefined }
+ strategy?: { highWaterMark?: number; size?: undefined },
): ReadableStream<Uint8Array>;
new <R = any>(
underlyingSource?: UnderlyingSource<R>,
- strategy?: QueuingStrategy<R>
+ strategy?: QueuingStrategy<R>,
): ReadableStream<R>;
};
@@ -428,9 +428,11 @@ interface WritableStreamDefaultControllerStartCallback {
}
interface WritableStreamDefaultControllerWriteCallback<W> {
- (chunk: W, controller: WritableStreamDefaultController): void | PromiseLike<
- void
- >;
+ (chunk: W, controller: WritableStreamDefaultController):
+ | void
+ | PromiseLike<
+ void
+ >;
}
interface WritableStreamErrorCallback {
@@ -451,7 +453,7 @@ interface UnderlyingSink<W = any> {
declare class WritableStream<W = any> {
constructor(
underlyingSink?: UnderlyingSink<W>,
- strategy?: QueuingStrategy<W>
+ strategy?: QueuingStrategy<W>,
);
readonly locked: boolean;
abort(reason?: any): Promise<void>;
@@ -485,7 +487,7 @@ declare class TransformStream<I = any, O = any> {
constructor(
transformer?: Transformer<I, O>,
writableStrategy?: QueuingStrategy<I>,
- readableStrategy?: QueuingStrategy<O>
+ readableStrategy?: QueuingStrategy<O>,
);
readonly readable: ReadableStream<O>;
readonly writable: WritableStream<I>;
@@ -513,7 +515,7 @@ interface TransformStreamDefaultControllerCallback<O> {
interface TransformStreamDefaultControllerTransformCallback<I, O> {
(
chunk: I,
- controller: TransformStreamDefaultController<O>
+ controller: TransformStreamDefaultController<O>,
): void | PromiseLike<void>;
}
@@ -589,7 +591,7 @@ declare class Console {
options?: Partial<{
depth: number;
indentLevel: number;
- }>
+ }>,
) => void;
/** From MDN:
@@ -609,7 +611,7 @@ declare class Console {
depth: number;
colors: boolean;
indentLevel: number;
- }>
+ }>,
) => void;
/** Writes the arguments to stdout */
@@ -650,9 +652,9 @@ declare interface Crypto {
| Float32Array
| Float64Array
| DataView
- | null
+ | null,
>(
- array: T
+ array: T,
): T;
}
@@ -724,7 +726,7 @@ interface Headers {
set(name: string, value: string): void;
forEach(
callbackfn: (value: string, key: string, parent: Headers) => void,
- thisArg?: any
+ thisArg?: any,
): void;
}
@@ -762,7 +764,7 @@ interface Headers extends DomIterable<string, string> {
values(): IterableIterator<string>;
forEach(
callbackfn: (value: string, key: string, parent: this) => void,
- thisArg?: any
+ thisArg?: any,
): void;
/** The Symbol.iterator well-known symbol specifies the default
* iterator for this Headers object
@@ -1023,7 +1025,7 @@ declare const Response: {
*/
declare function fetch(
input: Request | URL | string,
- init?: RequestInit
+ init?: RequestInit,
): Promise<Response>;
/** Decodes a string of data which has been encoded using base-64 encoding.
@@ -1047,7 +1049,7 @@ declare class TextDecoder {
readonly ignoreBOM = false;
constructor(
label?: string,
- options?: { fatal?: boolean; ignoreBOM?: boolean }
+ options?: { fatal?: boolean; ignoreBOM?: boolean },
);
/** Returns the result of running encoding's decoder. */
decode(input?: BufferSource, options?: { stream?: false }): string;
@@ -1061,7 +1063,7 @@ declare class TextEncoder {
encode(input?: string): Uint8Array;
encodeInto(
input: string,
- dest: Uint8Array
+ dest: Uint8Array,
): { read: number; written: number };
readonly [Symbol.toStringTag]: string;
}
@@ -1148,7 +1150,7 @@ interface URLSearchParams {
*/
forEach(
callbackfn: (value: string, key: string, parent: this) => void,
- thisArg?: any
+ thisArg?: any,
): void;
/** Returns an iterator allowing to go through all keys contained
@@ -1211,7 +1213,7 @@ interface URLSearchParams {
declare const URLSearchParams: {
prototype: URLSearchParams;
new (
- init?: string[][] | Record<string, string> | string | URLSearchParams
+ init?: string[][] | Record<string, string> | string | URLSearchParams,
): URLSearchParams;
toString(): string;
};
@@ -1330,7 +1332,7 @@ declare class Worker extends EventTarget {
*
*/
deno?: boolean;
- }
+ },
);
postMessage(message: any, transfer: ArrayBuffer[]): void;
postMessage(message: any, options?: PostMessageOptions): void;
@@ -1357,14 +1359,14 @@ declare interface Performance {
* associated name (a "measure"). */
measure(
measureName: string,
- options?: PerformanceMeasureOptions
+ options?: PerformanceMeasureOptions,
): PerformanceMeasure;
/** Stores the `DOMHighResTimeStamp` duration between two marks along with the
* associated name (a "measure"). */
measure(
measureName: string,
startMark?: string,
- endMark?: string
+ endMark?: string,
): PerformanceMeasure;
/** Returns a current time from Deno's start in milliseconds.
@@ -1540,7 +1542,7 @@ declare class EventTarget {
addEventListener(
type: string,
listener: EventListenerOrEventListenerObject | null,
- options?: boolean | AddEventListenerOptions
+ options?: boolean | AddEventListenerOptions,
): void;
/** Dispatches a synthetic event event to target and returns true if either
* event's cancelable attribute value is false or its preventDefault() method
@@ -1551,7 +1553,7 @@ declare class EventTarget {
removeEventListener(
type: string,
callback: EventListenerOrEventListenerObject | null,
- options?: EventListenerOptions | boolean
+ options?: EventListenerOptions | boolean,
): void;
[Symbol.toStringTag]: string;
}
@@ -1622,22 +1624,22 @@ interface AbortSignal extends EventTarget {
addEventListener<K extends keyof AbortSignalEventMap>(
type: K,
listener: (this: AbortSignal, ev: AbortSignalEventMap[K]) => any,
- options?: boolean | AddEventListenerOptions
+ options?: boolean | AddEventListenerOptions,
): void;
addEventListener(
type: string,
listener: EventListenerOrEventListenerObject,
- options?: boolean | AddEventListenerOptions
+ options?: boolean | AddEventListenerOptions,
): void;
removeEventListener<K extends keyof AbortSignalEventMap>(
type: K,
listener: (this: AbortSignal, ev: AbortSignalEventMap[K]) => any,
- options?: boolean | EventListenerOptions
+ options?: boolean | EventListenerOptions,
): void;
removeEventListener(
type: string,
listener: EventListenerOrEventListenerObject,
- options?: boolean | EventListenerOptions
+ options?: boolean | EventListenerOptions,
): void;
}
diff --git a/cli/js/lib.deno.unstable.d.ts b/cli/js/lib.deno.unstable.d.ts
index 05508a363..d23536c42 100644
--- a/cli/js/lib.deno.unstable.d.ts
+++ b/cli/js/lib.deno.unstable.d.ts
@@ -52,7 +52,7 @@ declare namespace Deno {
* ```
*/
export function consoleSize(
- rid: number
+ rid: number,
): {
columns: number;
rows: number;
@@ -77,7 +77,7 @@ declare namespace Deno {
export function symlinkSync(
oldpath: string,
newpath: string,
- options?: SymlinkOptions
+ options?: SymlinkOptions,
): void;
/** **UNSTABLE**: This API needs a security review.
@@ -95,7 +95,7 @@ declare namespace Deno {
export function symlink(
oldpath: string,
newpath: string,
- options?: SymlinkOptions
+ options?: SymlinkOptions,
): Promise<void>;
/** **Unstable** There are questions around which permission this needs. And
@@ -454,7 +454,7 @@ declare namespace Deno {
*/
export function transpileOnly(
sources: Record<string, string>,
- options?: CompilerOptions
+ options?: CompilerOptions,
): Promise<Record<string, TranspileOnlyResult>>;
/** **UNSTABLE**: new API, yet to be vetted.
@@ -492,7 +492,7 @@ declare namespace Deno {
export function compile(
rootName: string,
sources?: Record<string, string>,
- options?: CompilerOptions
+ options?: CompilerOptions,
): Promise<[DiagnosticItem[] | undefined, Record<string, string>]>;
/** **UNSTABLE**: new API, yet to be vetted.
@@ -535,7 +535,7 @@ declare namespace Deno {
export function bundle(
rootName: string,
sources?: Record<string, string>,
- options?: CompilerOptions
+ options?: CompilerOptions,
): Promise<[DiagnosticItem[] | undefined, string]>;
/** **UNSTABLE**: Should not have same name as `window.location` type. */
@@ -657,7 +657,7 @@ declare namespace Deno {
constructor(signal: typeof Deno.Signal);
then<T, S>(
f: (v: void) => T | Promise<T>,
- g?: (v: void) => S | Promise<S>
+ g?: (v: void) => S | Promise<S>,
): Promise<T | S>;
next(): Promise<IteratorResult<void>>;
[Symbol.asyncIterator](): AsyncIterableIterator<void>;
@@ -777,7 +777,7 @@ declare namespace Deno {
export function utimeSync(
path: string,
atime: number | Date,
- mtime: number | Date
+ mtime: number | Date,
): void;
/** **UNSTABLE**: needs investigation into high precision time.
@@ -794,7 +794,7 @@ declare namespace Deno {
export function utime(
path: string,
atime: number | Date,
- mtime: number | Date
+ mtime: number | Date,
): Promise<void>;
/** **UNSTABLE**: Under consideration to remove `ShutdownMode` entirely.
@@ -860,7 +860,7 @@ declare namespace Deno {
*
* Requires `allow-read` and `allow-write` permission. */
export function listen(
- options: UnixListenOptions & { transport: "unix" }
+ options: UnixListenOptions & { transport: "unix" },
): Listener;
/** **UNSTABLE**: new API, yet to be vetted
@@ -881,7 +881,7 @@ declare namespace Deno {
*
* Requires `allow-net` permission. */
export function listenDatagram(
- options: ListenOptions & { transport: "udp" }
+ options: ListenOptions & { transport: "udp" },
): DatagramConn;
/** **UNSTABLE**: new API, yet to be vetted
@@ -897,7 +897,7 @@ declare namespace Deno {
*
* Requires `allow-read` and `allow-write` permission. */
export function listenDatagram(
- options: UnixListenOptions & { transport: "unixpacket" }
+ options: UnixListenOptions & { transport: "unixpacket" },
): DatagramConn;
export interface UnixConnectOptions {
@@ -921,7 +921,7 @@ declare namespace Deno {
*
* Requires `allow-net` permission for "tcp" and `allow-read` for "unix". */
export function connect(
- options: ConnectOptions | UnixConnectOptions
+ options: ConnectOptions | UnixConnectOptions,
): Promise<Conn>;
export interface StartTlsOptions {
@@ -950,7 +950,7 @@ declare namespace Deno {
*/
export function startTls(
conn: Conn,
- options?: StartTlsOptions
+ options?: StartTlsOptions,
): Promise<Conn>;
/** **UNSTABLE**: The `signo` argument may change to require the Deno.Signal
diff --git a/cli/js/lib.deno.worker.d.ts b/cli/js/lib.deno.worker.d.ts
index 5343646f6..95aa16139 100644
--- a/cli/js/lib.deno.worker.d.ts
+++ b/cli/js/lib.deno.worker.d.ts
@@ -22,12 +22,12 @@ declare const self: DedicatedWorkerGlobalScope & typeof globalThis;
declare let onmessage: ((e: { data: any }) => Promise<void> | void) | undefined;
declare let onerror:
| ((
- msg: string,
- source: string,
- lineno: number,
- colno: number,
- e: Event
- ) => boolean | void)
+ msg: string,
+ source: string,
+ lineno: number,
+ colno: number,
+ e: Event,
+ ) => boolean | void)
| undefined;
declare const close: typeof __workerMain.close;
declare const name: typeof __workerMain.name;
diff --git a/cli/js/net.ts b/cli/js/net.ts
index a4aad0254..07feb89fe 100644
--- a/cli/js/net.ts
+++ b/cli/js/net.ts
@@ -37,7 +37,7 @@ export class ConnImpl implements Conn {
constructor(
readonly rid: number,
readonly remoteAddr: Addr,
- readonly localAddr: Addr
+ readonly localAddr: Addr,
) {}
write(p: Uint8Array): Promise<number> {
@@ -97,7 +97,7 @@ export class DatagramImpl implements DatagramConn {
constructor(
readonly rid: number,
readonly addr: Addr,
- public bufSize: number = 1024
+ public bufSize: number = 1024,
) {}
async receive(p?: Uint8Array): Promise<[Uint8Array, Addr]> {
@@ -105,7 +105,7 @@ export class DatagramImpl implements DatagramConn {
const { size, remoteAddr } = await netOps.receive(
this.rid,
this.addr.transport,
- buf
+ buf,
);
const sub = buf.subarray(0, size);
return [sub, remoteAddr];
@@ -150,7 +150,7 @@ export interface ListenOptions {
}
export function listen(
- options: ListenOptions & { transport?: "tcp" }
+ options: ListenOptions & { transport?: "tcp" },
): Listener;
export function listen(options: ListenOptions): Listener {
const res = netOps.listen({
@@ -174,7 +174,7 @@ export interface UnixConnectOptions {
export async function connect(options: UnixConnectOptions): Promise<Conn>;
export async function connect(options: ConnectOptions): Promise<Conn>;
export async function connect(
- options: ConnectOptions | UnixConnectOptions
+ options: ConnectOptions | UnixConnectOptions,
): Promise<Conn> {
let res;
diff --git a/cli/js/net_unstable.ts b/cli/js/net_unstable.ts
index 9a1d1f568..cedb68b23 100644
--- a/cli/js/net_unstable.ts
+++ b/cli/js/net_unstable.ts
@@ -30,10 +30,10 @@ export interface UnixConnectOptions {
}
export function listen(
- options: ListenOptions & { transport?: "tcp" }
+ options: ListenOptions & { transport?: "tcp" },
): Listener;
export function listen(
- options: UnixListenOptions & { transport: "unix" }
+ options: UnixListenOptions & { transport: "unix" },
): Listener;
export function listen(options: ListenOptions | UnixListenOptions): Listener {
if (options.transport === "unix") {
@@ -45,13 +45,13 @@ export function listen(options: ListenOptions | UnixListenOptions): Listener {
}
export function listenDatagram(
- options: ListenOptions & { transport: "udp" }
+ options: ListenOptions & { transport: "udp" },
): DatagramConn;
export function listenDatagram(
- options: UnixListenOptions & { transport: "unixpacket" }
+ options: UnixListenOptions & { transport: "unixpacket" },
): DatagramConn;
export function listenDatagram(
- options: ListenOptions | UnixListenOptions
+ options: ListenOptions | UnixListenOptions,
): DatagramConn {
let res;
if (options.transport === "unixpacket") {
@@ -68,7 +68,7 @@ export function listenDatagram(
}
export async function connect(
- options: ConnectOptions | UnixConnectOptions
+ options: ConnectOptions | UnixConnectOptions,
): Promise<Conn> {
if (options.transport === "unix") {
const res = await netOps.connect(options);
diff --git a/cli/js/ops/dispatch_minimal.ts b/cli/js/ops/dispatch_minimal.ts
index ca50b00e9..cc1d97e20 100644
--- a/cli/js/ops/dispatch_minimal.ts
+++ b/cli/js/ops/dispatch_minimal.ts
@@ -37,7 +37,7 @@ export function recordFromBufMinimal(ui8: Uint8Array): RecordMinimal {
const buf32 = new Int32Array(
header.buffer,
header.byteOffset,
- header.byteLength / 4
+ header.byteLength / 4,
);
const promiseId = buf32[0];
const arg = buf32[1];
@@ -71,7 +71,7 @@ const scratch32 = new Int32Array(3);
const scratchBytes = new Uint8Array(
scratch32.buffer,
scratch32.byteOffset,
- scratch32.byteLength
+ scratch32.byteLength,
);
util.assert(scratchBytes.byteLength === scratch32.length * 4);
@@ -87,7 +87,7 @@ export function asyncMsgFromRust(ui8: Uint8Array): void {
export async function sendAsyncMinimal(
opName: string,
arg: number,
- zeroCopy: Uint8Array
+ zeroCopy: Uint8Array,
): Promise<number> {
const promiseId = nextPromiseId(); // AKA cmdId
scratch32[0] = promiseId;
@@ -111,7 +111,7 @@ export async function sendAsyncMinimal(
export function sendSyncMinimal(
opName: string,
arg: number,
- zeroCopy: Uint8Array
+ zeroCopy: Uint8Array,
): number {
scratch32[0] = 0; // promiseId 0 indicates sync
scratch32[1] = arg;
diff --git a/cli/js/ops/fetch.ts b/cli/js/ops/fetch.ts
index 2f881cc02..e349b9de5 100644
--- a/cli/js/ops/fetch.ts
+++ b/cli/js/ops/fetch.ts
@@ -17,7 +17,7 @@ export interface FetchResponse {
export function fetch(
args: FetchRequest,
- body?: ArrayBufferView
+ body?: ArrayBufferView,
): Promise<FetchResponse> {
let zeroCopy;
if (body != null) {
diff --git a/cli/js/ops/fs/chown.ts b/cli/js/ops/fs/chown.ts
index 52735e097..054b61f6c 100644
--- a/cli/js/ops/fs/chown.ts
+++ b/cli/js/ops/fs/chown.ts
@@ -6,7 +6,7 @@ import { pathFromURL } from "../../util.ts";
export function chownSync(
path: string | URL,
uid: number | null,
- gid: number | null
+ gid: number | null,
): void {
sendSync("op_chown", { path: pathFromURL(path), uid, gid });
}
@@ -14,7 +14,7 @@ export function chownSync(
export async function chown(
path: string | URL,
uid: number | null,
- gid: number | null
+ gid: number | null,
): Promise<void> {
await sendAsync("op_chown", { path: pathFromURL(path), uid, gid });
}
diff --git a/cli/js/ops/fs/copy_file.ts b/cli/js/ops/fs/copy_file.ts
index fcb147bdd..d2d2d5688 100644
--- a/cli/js/ops/fs/copy_file.ts
+++ b/cli/js/ops/fs/copy_file.ts
@@ -5,7 +5,7 @@ import { pathFromURL } from "../../util.ts";
export function copyFileSync(
fromPath: string | URL,
- toPath: string | URL
+ toPath: string | URL,
): void {
sendSync("op_copy_file", {
from: pathFromURL(fromPath),
@@ -15,7 +15,7 @@ export function copyFileSync(
export async function copyFile(
fromPath: string | URL,
- toPath: string | URL
+ toPath: string | URL,
): Promise<void> {
await sendAsync("op_copy_file", {
from: pathFromURL(fromPath),
diff --git a/cli/js/ops/fs/mkdir.ts b/cli/js/ops/fs/mkdir.ts
index 61ea1c218..790b2ad05 100644
--- a/cli/js/ops/fs/mkdir.ts
+++ b/cli/js/ops/fs/mkdir.ts
@@ -32,7 +32,7 @@ export function mkdirSync(path: string, options?: MkdirOptions): void {
export async function mkdir(
path: string,
- options?: MkdirOptions
+ options?: MkdirOptions,
): Promise<void> {
await sendAsync("op_mkdir", mkdirArgs(path, options));
}
diff --git a/cli/js/ops/fs/open.ts b/cli/js/ops/fs/open.ts
index edd52c376..f2cad5988 100644
--- a/cli/js/ops/fs/open.ts
+++ b/cli/js/ops/fs/open.ts
@@ -24,7 +24,7 @@ export function openSync(path: string | URL, options: OpenOptions): number {
export function open(
path: string | URL,
- options: OpenOptions
+ options: OpenOptions,
): Promise<number> {
const mode: number | undefined = options?.mode;
return sendAsync("op_open", { path: pathFromURL(path), options, mode });
diff --git a/cli/js/ops/fs/remove.ts b/cli/js/ops/fs/remove.ts
index 52f4cad40..24e23986c 100644
--- a/cli/js/ops/fs/remove.ts
+++ b/cli/js/ops/fs/remove.ts
@@ -9,7 +9,7 @@ export interface RemoveOptions {
export function removeSync(
path: string | URL,
- options: RemoveOptions = {}
+ options: RemoveOptions = {},
): void {
sendSync("op_remove", {
path: pathFromURL(path),
@@ -19,7 +19,7 @@ export function removeSync(
export async function remove(
path: string | URL,
- options: RemoveOptions = {}
+ options: RemoveOptions = {},
): Promise<void> {
await sendAsync("op_remove", {
path: pathFromURL(path),
diff --git a/cli/js/ops/fs/seek.ts b/cli/js/ops/fs/seek.ts
index 8fd3964fd..4f97514ed 100644
--- a/cli/js/ops/fs/seek.ts
+++ b/cli/js/ops/fs/seek.ts
@@ -6,7 +6,7 @@ import type { SeekMode } from "../../io.ts";
export function seekSync(
rid: number,
offset: number,
- whence: SeekMode
+ whence: SeekMode,
): number {
return sendSync("op_seek", { rid, offset, whence });
}
@@ -14,7 +14,7 @@ export function seekSync(
export function seek(
rid: number,
offset: number,
- whence: SeekMode
+ whence: SeekMode,
): Promise<number> {
return sendAsync("op_seek", { rid, offset, whence });
}
diff --git a/cli/js/ops/fs/symlink.ts b/cli/js/ops/fs/symlink.ts
index 7d4741928..d96e05f24 100644
--- a/cli/js/ops/fs/symlink.ts
+++ b/cli/js/ops/fs/symlink.ts
@@ -9,7 +9,7 @@ export interface SymlinkOptions {
export function symlinkSync(
oldpath: string,
newpath: string,
- options?: SymlinkOptions
+ options?: SymlinkOptions,
): void {
sendSync("op_symlink", { oldpath, newpath, options });
}
@@ -17,7 +17,7 @@ export function symlinkSync(
export async function symlink(
oldpath: string,
newpath: string,
- options?: SymlinkOptions
+ options?: SymlinkOptions,
): Promise<void> {
await sendAsync("op_symlink", { oldpath, newpath, options });
}
diff --git a/cli/js/ops/fs/utime.ts b/cli/js/ops/fs/utime.ts
index fa86038c6..bbc023ae9 100644
--- a/cli/js/ops/fs/utime.ts
+++ b/cli/js/ops/fs/utime.ts
@@ -9,7 +9,7 @@ function toSecondsFromEpoch(v: number | Date): number {
export function utimeSync(
path: string,
atime: number | Date,
- mtime: number | Date
+ mtime: number | Date,
): void {
sendSync("op_utime", {
path,
@@ -22,7 +22,7 @@ export function utimeSync(
export async function utime(
path: string,
atime: number | Date,
- mtime: number | Date
+ mtime: number | Date,
): Promise<void> {
await sendAsync("op_utime", {
path,
diff --git a/cli/js/ops/fs_events.ts b/cli/js/ops/fs_events.ts
index fb78c6196..ffe19b4d7 100644
--- a/cli/js/ops/fs_events.ts
+++ b/cli/js/ops/fs_events.ts
@@ -38,7 +38,7 @@ class FsWatcher implements AsyncIterableIterator<FsEvent> {
export function watchFs(
paths: string | string[],
- options: FsWatcherOptions = { recursive: true }
+ options: FsWatcherOptions = { recursive: true },
): AsyncIterableIterator<FsEvent> {
return new FsWatcher(Array.isArray(paths) ? paths : [paths], options);
}
diff --git a/cli/js/ops/get_random_values.ts b/cli/js/ops/get_random_values.ts
index 95e4602e6..5a45a79d7 100644
--- a/cli/js/ops/get_random_values.ts
+++ b/cli/js/ops/get_random_values.ts
@@ -11,14 +11,14 @@ export function getRandomValues<
| Int16Array
| Uint16Array
| Int32Array
- | Uint32Array
+ | Uint32Array,
>(typedArray: T): T {
assert(typedArray !== null, "Input must not be null");
assert(typedArray.length <= 65536, "Input must not be longer than 65536");
const ui8 = new Uint8Array(
typedArray.buffer,
typedArray.byteOffset,
- typedArray.byteLength
+ typedArray.byteLength,
);
sendSync("op_get_random_values", {}, ui8);
return typedArray;
diff --git a/cli/js/ops/idna.ts b/cli/js/ops/idna.ts
index 8459ca29c..59a9af030 100644
--- a/cli/js/ops/idna.ts
+++ b/cli/js/ops/idna.ts
@@ -6,7 +6,7 @@ import { sendSync } from "./dispatch_json.ts";
export function domainToAscii(
domain: string,
- { beStrict = false }: { beStrict?: boolean } = {}
+ { beStrict = false }: { beStrict?: boolean } = {},
): string {
return sendSync("op_domain_to_ascii", { domain, beStrict });
}
diff --git a/cli/js/ops/io.ts b/cli/js/ops/io.ts
index ecd1269d5..355a09ae0 100644
--- a/cli/js/ops/io.ts
+++ b/cli/js/ops/io.ts
@@ -17,7 +17,7 @@ export function readSync(rid: number, buffer: Uint8Array): number | null {
export async function read(
rid: number,
- buffer: Uint8Array
+ buffer: Uint8Array,
): Promise<number | null> {
if (buffer.length === 0) {
return 0;
diff --git a/cli/js/ops/net.ts b/cli/js/ops/net.ts
index 05b1bc2cd..1dfa92bd1 100644
--- a/cli/js/ops/net.ts
+++ b/cli/js/ops/net.ts
@@ -36,7 +36,7 @@ interface AcceptResponse {
export function accept(
rid: number,
- transport: string
+ transport: string,
): Promise<AcceptResponse> {
return sendAsync("op_accept", { rid, transport });
}
@@ -72,7 +72,7 @@ interface ReceiveResponse {
export function receive(
rid: number,
transport: string,
- zeroCopy: Uint8Array
+ zeroCopy: Uint8Array,
): Promise<ReceiveResponse> {
return sendAsync("op_datagram_receive", { rid, transport }, zeroCopy);
}
diff --git a/cli/js/ops/runtime_compiler.ts b/cli/js/ops/runtime_compiler.ts
index 671585118..ed439de4a 100644
--- a/cli/js/ops/runtime_compiler.ts
+++ b/cli/js/ops/runtime_compiler.ts
@@ -31,7 +31,7 @@ export interface TranspileOnlyResult {
}
export function transpile(
- request: TranspileRequest
+ request: TranspileRequest,
): Promise<Record<string, TranspileOnlyResult>> {
return sendAsync("op_transpile", request);
}
diff --git a/cli/js/ops/tls.ts b/cli/js/ops/tls.ts
index b278c2d75..291fe3dd9 100644
--- a/cli/js/ops/tls.ts
+++ b/cli/js/ops/tls.ts
@@ -24,7 +24,7 @@ interface EstablishTLSResponse {
}
export function connectTls(
- args: ConnectTLSRequest
+ args: ConnectTLSRequest,
): Promise<EstablishTLSResponse> {
return sendAsync("op_connect_tls", args);
}
diff --git a/cli/js/ops/worker_host.ts b/cli/js/ops/worker_host.ts
index 24e6b57ba..d5adfc3d5 100644
--- a/cli/js/ops/worker_host.ts
+++ b/cli/js/ops/worker_host.ts
@@ -12,7 +12,7 @@ export function createWorker(
hasSourceCode: boolean,
sourceCode: string,
useDenoNamespace: boolean,
- name?: string
+ name?: string,
): CreateWorkerResponse {
return sendSync("op_create_worker", {
specifier,
diff --git a/cli/js/process.ts b/cli/js/process.ts
index ee32eac3d..0844dd8fd 100644
--- a/cli/js/process.ts
+++ b/cli/js/process.ts
@@ -33,14 +33,11 @@ async function runStatus(rid: number): Promise<ProcessStatus> {
export class Process<T extends RunOptions = RunOptions> {
readonly rid: number;
readonly pid: number;
- readonly stdin!: T["stdin"] extends "piped"
- ? Writer & Closer
+ readonly stdin!: T["stdin"] extends "piped" ? Writer & Closer
: (Writer & Closer) | null;
- readonly stdout!: T["stdout"] extends "piped"
- ? Reader & Closer
+ readonly stdout!: T["stdout"] extends "piped" ? Reader & Closer
: (Reader & Closer) | null;
- readonly stderr!: T["stderr"] extends "piped"
- ? Reader & Closer
+ readonly stderr!: T["stderr"] extends "piped" ? Reader & Closer
: (Reader & Closer) | null;
// @internal
diff --git a/cli/js/repl.ts b/cli/js/repl.ts
index 8a37d991f..9f2693de6 100644
--- a/cli/js/repl.ts
+++ b/cli/js/repl.ts
@@ -56,10 +56,9 @@ function evaluate(code: string): boolean {
if (!errInfo) {
// when a function is eval'ed with just "use strict" sometimes the result
// is "use strict" which should be discarded
- lastEvalResult =
- typeof result === "string" && result === "use strict"
- ? undefined
- : result;
+ lastEvalResult = typeof result === "string" && result === "use strict"
+ ? undefined
+ : result;
if (!isCloseCalled()) {
replLog(lastEvalResult);
}
diff --git a/cli/js/runtime_main.ts b/cli/js/runtime_main.ts
index 0c579626b..2983fd47f 100644
--- a/cli/js/runtime_main.ts
+++ b/cli/js/runtime_main.ts
@@ -48,7 +48,7 @@ function windowClose(): void {
// This should be fine, since only Window/MainWorker has .close()
exit(0);
},
- 0
+ 0,
)
);
}
diff --git a/cli/js/runtime_worker.ts b/cli/js/runtime_worker.ts
index 3f7816990..9904ab012 100644
--- a/cli/js/runtime_worker.ts
+++ b/cli/js/runtime_worker.ts
@@ -93,7 +93,7 @@ export async function workerMessageRecvCallback(data: string): Promise<void> {
e.fileName,
e.lineNumber,
e.columnNumber,
- e
+ e,
);
handled = ret === true;
}
@@ -122,7 +122,7 @@ export const workerRuntimeGlobalProperties = {
export function bootstrapWorkerRuntime(
name: string,
useDenoNamespace: boolean,
- internalName?: string
+ internalName?: string,
): void {
if (hasBootstrapped) {
throw new Error("Worker runtime already bootstrapped");
@@ -139,7 +139,7 @@ export function bootstrapWorkerRuntime(
Object.defineProperties(globalThis, { name: readOnly(name) });
setEventTargetData(globalThis);
const { unstableFlag, pid, noColor, args } = runtime.start(
- internalName ?? name
+ internalName ?? name,
);
if (unstableFlag) {
diff --git a/cli/js/signals.ts b/cli/js/signals.ts
index 64cf4106b..a29bac0d7 100644
--- a/cli/js/signals.ts
+++ b/cli/js/signals.ts
@@ -150,7 +150,7 @@ export class SignalStream
then<T, S>(
f: (v: void) => T | Promise<T>,
- g?: (v: Error) => S | Promise<S>
+ g?: (v: Error) => S | Promise<S>,
): Promise<T | S> {
return this.#pollingPromise.then(() => {}).then(f, g);
}
diff --git a/cli/js/testing.ts b/cli/js/testing.ts
index d38c5427d..accbb81ee 100644
--- a/cli/js/testing.ts
+++ b/cli/js/testing.ts
@@ -52,7 +52,7 @@ After:
- completed: ${post.opsCompletedAsync}
Make sure to await all promises returned from Deno APIs before
-finishing test case.`
+finishing test case.`,
);
};
}
@@ -61,7 +61,7 @@ finishing test case.`
// the test case does not "leak" resources - ie. resource table after
// the test has exactly the same contents as before the test.
function assertResources(
- fn: () => void | Promise<void>
+ fn: () => void | Promise<void>,
): () => void | Promise<void> {
return async function resourceSanitizer(): Promise<void> {
const pre = resources();
@@ -97,7 +97,7 @@ export function test(name: string, fn: () => void | Promise<void>): void;
// creates a new object with "name" and "fn" fields.
export function test(
t: string | TestDefinition,
- fn?: () => void | Promise<void>
+ fn?: () => void | Promise<void>,
): void {
let testDef: TestDefinition;
const defaults = {
@@ -220,7 +220,7 @@ function reportToConsole(message: TestMessage): void {
`${message.end.passed} passed; ${message.end.failed} failed; ` +
`${message.end.ignored} ignored; ${message.end.measured} measured; ` +
`${message.end.filtered} filtered out ` +
- `${formatDuration(message.end.duration)}\n`
+ `${formatDuration(message.end.duration)}\n`,
);
if (message.end.usedOnly && message.end.failed == 0) {
@@ -247,7 +247,7 @@ class TestRunner {
constructor(
tests: TestDefinition[],
public filterFn: (def: TestDefinition) => boolean,
- public failFast: boolean
+ public failFast: boolean,
) {
const onlyTests = tests.filter(({ only }) => only);
this.#usedOnly = onlyTests.length > 0;
@@ -300,7 +300,7 @@ class TestRunner {
function createFilterFn(
filter: undefined | string | RegExp,
- skip: undefined | string | RegExp
+ skip: undefined | string | RegExp,
): (def: TestDefinition) => boolean {
return (def: TestDefinition): boolean => {
let passes = true;
diff --git a/cli/js/tls.ts b/cli/js/tls.ts
index f0506898c..f266a16ea 100644
--- a/cli/js/tls.ts
+++ b/cli/js/tls.ts
@@ -66,7 +66,7 @@ interface StartTlsOptions {
export async function startTls(
conn: Conn,
- { hostname = "127.0.0.1", certFile }: StartTlsOptions = {}
+ { hostname = "127.0.0.1", certFile }: StartTlsOptions = {},
): Promise<Conn> {
const res = await tlsOps.startTls({
rid: conn.rid,
diff --git a/cli/js/util.ts b/cli/js/util.ts
index 50a38978e..f1aefb601 100644
--- a/cli/js/util.ts
+++ b/cli/js/util.ts
@@ -73,7 +73,7 @@ export function immutableDefine(
o: any,
p: string | number | symbol,
// eslint-disable-next-line @typescript-eslint/no-explicit-any
- value: any
+ value: any,
): void {
Object.defineProperty(o, p, {
value,
diff --git a/cli/js/version.ts b/cli/js/version.ts
index ff9b5e972..30157af04 100644
--- a/cli/js/version.ts
+++ b/cli/js/version.ts
@@ -15,7 +15,7 @@ export const version: Version = {
export function setVersions(
denoVersion: string,
v8Version: string,
- tsVersion: string
+ tsVersion: string,
): void {
version.deno = denoVersion;
version.v8 = v8Version;
diff --git a/cli/js/web/base64.ts b/cli/js/web/base64.ts
index 328311d03..6f2459b92 100644
--- a/cli/js/web/base64.ts
+++ b/cli/js/web/base64.ts
@@ -45,7 +45,7 @@ export function byteLength(b64: string): number {
function _byteLength(
b64: string,
validLen: number,
- placeHoldersLen: number
+ placeHoldersLen: number,
): number {
return ((validLen + placeHoldersLen) * 3) / 4 - placeHoldersLen;
}
@@ -65,8 +65,7 @@ export function toByteArray(b64: string): Uint8Array {
let i;
for (i = 0; i < len; i += 4) {
- tmp =
- (revLookup[b64.charCodeAt(i)] << 18) |
+ tmp = (revLookup[b64.charCodeAt(i)] << 18) |
(revLookup[b64.charCodeAt(i + 1)] << 12) |
(revLookup[b64.charCodeAt(i + 2)] << 6) |
revLookup[b64.charCodeAt(i + 3)];
@@ -76,15 +75,13 @@ export function toByteArray(b64: string): Uint8Array {
}
if (placeHoldersLen === 2) {
- tmp =
- (revLookup[b64.charCodeAt(i)] << 2) |
+ tmp = (revLookup[b64.charCodeAt(i)] << 2) |
(revLookup[b64.charCodeAt(i + 1)] >> 4);
arr[curByte++] = tmp & 0xff;
}
if (placeHoldersLen === 1) {
- tmp =
- (revLookup[b64.charCodeAt(i)] << 10) |
+ tmp = (revLookup[b64.charCodeAt(i)] << 10) |
(revLookup[b64.charCodeAt(i + 1)] << 4) |
(revLookup[b64.charCodeAt(i + 2)] >> 2);
arr[curByte++] = (tmp >> 8) & 0xff;
@@ -107,8 +104,7 @@ function encodeChunk(uint8: Uint8Array, start: number, end: number): string {
let tmp;
const output = [];
for (let i = start; i < end; i += 3) {
- tmp =
- ((uint8[i] << 16) & 0xff0000) +
+ tmp = ((uint8[i] << 16) & 0xff0000) +
((uint8[i + 1] << 8) & 0xff00) +
(uint8[i + 2] & 0xff);
output.push(tripletToBase64(tmp));
@@ -129,8 +125,8 @@ export function fromByteArray(uint8: Uint8Array): string {
encodeChunk(
uint8,
i,
- i + maxChunkLength > len2 ? len2 : i + maxChunkLength
- )
+ i + maxChunkLength > len2 ? len2 : i + maxChunkLength,
+ ),
);
}
@@ -144,7 +140,7 @@ export function fromByteArray(uint8: Uint8Array): string {
lookup[tmp >> 10] +
lookup[(tmp >> 4) & 0x3f] +
lookup[(tmp << 2) & 0x3f] +
- "="
+ "=",
);
}
diff --git a/cli/js/web/blob.ts b/cli/js/web/blob.ts
index 92286029f..7034da723 100644
--- a/cli/js/web/blob.ts
+++ b/cli/js/web/blob.ts
@@ -51,7 +51,7 @@ function convertLineEndingsToNative(s: string): string {
function collectSequenceNotCRLF(
s: string,
- position: number
+ position: number,
): { collected: string; newPosition: number } {
const start = position;
for (
@@ -64,7 +64,7 @@ function collectSequenceNotCRLF(
function toUint8Arrays(
blobParts: BlobPart[],
- doNormalizeLineEndingsToNative: boolean
+ doNormalizeLineEndingsToNative: boolean,
): Uint8Array[] {
const ret: Uint8Array[] = [];
const enc = new TextEncoder();
@@ -103,7 +103,7 @@ function toUint8Arrays(
function processBlobParts(
blobParts: BlobPart[],
- options: BlobPropertyBag
+ options: BlobPropertyBag,
): Uint8Array {
const normalizeLineEndingsToNative = options.ending === "native";
// ArrayBuffer.transfer is not yet implemented in V8, so we just have to
@@ -136,7 +136,7 @@ function getStream(blobBytes: Uint8Array): ReadableStream<ArrayBufferView> {
}
async function readBytes(
- reader: ReadableStreamReader<ArrayBufferView>
+ reader: ReadableStreamReader<ArrayBufferView>,
): Promise<ArrayBuffer> {
const chunks: Uint8Array[] = [];
while (true) {
diff --git a/cli/js/web/body.ts b/cli/js/web/body.ts
index 69aca459f..a7a120ad6 100644
--- a/cli/js/web/body.ts
+++ b/cli/js/web/body.ts
@@ -40,13 +40,13 @@ function validateBodyType(owner: Body, bodySource: BodyInit | null): boolean {
return true; // null body is fine
}
throw new Error(
- `Bad ${owner.constructor.name} body type: ${bodySource.constructor.name}`
+ `Bad ${owner.constructor.name} body type: ${bodySource.constructor.name}`,
);
}
async function bufferFromStream(
stream: ReadableStreamReader,
- size?: number
+ size?: number,
): Promise<ArrayBuffer> {
const encoder = new TextEncoder();
const buffer = new Buffer();
@@ -154,7 +154,7 @@ export class Body implements domTypes.Body {
const value = split.join("=").replace(/\+/g, " ");
formData.append(
decodeURIComponent(name),
- decodeURIComponent(value)
+ decodeURIComponent(value),
);
}
});
@@ -191,7 +191,7 @@ export class Body implements domTypes.Body {
} else if (typeof this._bodySource === "string") {
const enc = new TextEncoder();
return Promise.resolve(
- enc.encode(this._bodySource).buffer as ArrayBuffer
+ enc.encode(this._bodySource).buffer as ArrayBuffer,
);
} else if (this._bodySource instanceof ReadableStreamImpl) {
return bufferFromStream(this._bodySource.getReader(), this.#size);
@@ -201,13 +201,13 @@ export class Body implements domTypes.Body {
) {
const enc = new TextEncoder();
return Promise.resolve(
- enc.encode(this._bodySource.toString()).buffer as ArrayBuffer
+ enc.encode(this._bodySource.toString()).buffer as ArrayBuffer,
);
} else if (!this._bodySource) {
return Promise.resolve(new ArrayBuffer(0));
}
throw new Error(
- `Body type not yet implemented: ${this._bodySource.constructor.name}`
+ `Body type not yet implemented: ${this._bodySource.constructor.name}`,
);
}
}
diff --git a/cli/js/web/console.ts b/cli/js/web/console.ts
index 5ddf50114..181cdb664 100644
--- a/cli/js/web/console.ts
+++ b/cli/js/web/console.ts
@@ -94,7 +94,7 @@ interface InspectIterableOptions<T> {
ctx: ConsoleContext,
level: number,
inspectOptions: Required<InspectOptions>,
- next: () => IteratorResult<[unknown, T], unknown>
+ next: () => IteratorResult<[unknown, T], unknown>,
) => string;
group: boolean;
sort: boolean;
@@ -107,7 +107,7 @@ function inspectIterable<T>(
ctx: ConsoleContext,
level: number,
options: InspectIterableOptions<T>,
- inspectOptions: Required<InspectOptions>
+ inspectOptions: Required<InspectOptions>,
): string {
if (level >= inspectOptions.depth) {
return cyan(`[${options.typeName}]`);
@@ -129,8 +129,8 @@ function inspectIterable<T>(
ctx,
level + 1,
inspectOptions,
- next.bind(iter)
- )
+ next.bind(iter),
+ ),
);
}
entriesLength++;
@@ -150,25 +150,25 @@ function inspectIterable<T>(
const initIndentation = `\n${DEFAULT_INDENT.repeat(level + 1)}`;
const entryIndentation = `,\n${DEFAULT_INDENT.repeat(level + 1)}`;
- const closingIndentation = `${
- inspectOptions.trailingComma ? "," : ""
- }\n${DEFAULT_INDENT.repeat(level)}`;
+ const closingIndentation = `${inspectOptions.trailingComma ? "," : ""}\n${
+ DEFAULT_INDENT.repeat(level)
+ }`;
let iContent: string;
if (options.group && entries.length > MIN_GROUP_LENGTH) {
const groups = groupEntries(entries, level, value);
- iContent = `${initIndentation}${groups.join(
- entryIndentation
- )}${closingIndentation}`;
+ iContent = `${initIndentation}${
+ groups.join(entryIndentation)
+ }${closingIndentation}`;
} else {
iContent = entries.length === 0 ? "" : ` ${entries.join(", ")} `;
if (
stripColor(iContent).length > LINE_BREAKING_LENGTH ||
!inspectOptions.compact
) {
- iContent = `${initIndentation}${entries.join(
- entryIndentation
- )}${closingIndentation}`;
+ iContent = `${initIndentation}${
+ entries.join(entryIndentation)
+ }${closingIndentation}`;
}
}
@@ -181,7 +181,7 @@ function groupEntries<T>(
entries: string[],
level: number,
value: Iterable<T>,
- iterableLimit = 100
+ iterableLimit = 100,
): string[] {
let totalLength = 0;
let maxLength = 0;
@@ -225,12 +225,12 @@ function groupEntries<T>(
// Divide that by `actualMax` to receive the correct number of columns.
// The added bias increases the columns for short entries.
Math.round(
- Math.sqrt(approxCharHeights * biasedMax * entriesLength) / biasedMax
+ Math.sqrt(approxCharHeights * biasedMax * entriesLength) / biasedMax,
),
// Do not exceed the breakLength.
Math.floor((LINE_BREAKING_LENGTH - (level + 1)) / actualMax),
// Limit the columns to a maximum of fifteen.
- 15
+ 15,
);
// Return with the original output if no grouping should happen.
if (columns <= 1) {
@@ -272,8 +272,7 @@ function groupEntries<T>(
str += `${entries[j]}, `[order](padding, " ");
}
if (order === "padStart") {
- const padding =
- maxLineLength[j - i] +
+ const padding = maxLineLength[j - i] +
entries[j].length -
dataLen[j] -
separatorSpace;
@@ -295,7 +294,7 @@ function inspectValue(
value: unknown,
ctx: ConsoleContext,
level: number,
- inspectOptions: Required<InspectOptions>
+ inspectOptions: Required<InspectOptions>,
): string {
switch (typeof value) {
case "string":
@@ -353,14 +352,13 @@ function inspectValueWithQuotes(
value: unknown,
ctx: ConsoleContext,
level: number,
- inspectOptions: Required<InspectOptions>
+ inspectOptions: Required<InspectOptions>,
): string {
switch (typeof value) {
case "string":
- const trunc =
- value.length > STR_ABBREVIATE_SIZE
- ? value.slice(0, STR_ABBREVIATE_SIZE) + "..."
- : value;
+ const trunc = value.length > STR_ABBREVIATE_SIZE
+ ? value.slice(0, STR_ABBREVIATE_SIZE) + "..."
+ : value;
return green(quoteString(trunc)); // Quoted strings are green
default:
return inspectValue(value, ctx, level, inspectOptions);
@@ -371,7 +369,7 @@ function inspectArray(
value: unknown[],
ctx: ConsoleContext,
level: number,
- inspectOptions: Required<InspectOptions>
+ inspectOptions: Required<InspectOptions>,
): string {
const options: InspectIterableOptions<unknown> = {
typeName: "Array",
@@ -404,7 +402,7 @@ function inspectTypedArray(
value: TypedArray,
ctx: ConsoleContext,
level: number,
- inspectOptions: Required<InspectOptions>
+ inspectOptions: Required<InspectOptions>,
): string {
const valueLength = value.length;
const options: InspectIterableOptions<unknown> = {
@@ -425,7 +423,7 @@ function inspectSet(
value: Set<unknown>,
ctx: ConsoleContext,
level: number,
- inspectOptions: Required<InspectOptions>
+ inspectOptions: Required<InspectOptions>,
): string {
const options: InspectIterableOptions<unknown> = {
typeName: "Set",
@@ -445,7 +443,7 @@ function inspectMap(
value: Map<unknown, unknown>,
ctx: ConsoleContext,
level: number,
- inspectOptions: Required<InspectOptions>
+ inspectOptions: Required<InspectOptions>,
): string {
const options: InspectIterableOptions<[unknown]> = {
typeName: "Map",
@@ -453,12 +451,14 @@ function inspectMap(
delims: ["{", "}"],
entryHandler: (entry, ctx, level, inspectOptions): string => {
const [key, val] = entry;
- return `${inspectValueWithQuotes(
- key,
- ctx,
- level + 1,
- inspectOptions
- )} => ${inspectValueWithQuotes(val, ctx, level + 1, inspectOptions)}`;
+ return `${
+ inspectValueWithQuotes(
+ key,
+ ctx,
+ level + 1,
+ inspectOptions,
+ )
+ } => ${inspectValueWithQuotes(val, ctx, level + 1, inspectOptions)}`;
},
group: false,
sort: inspectOptions.sorted,
@@ -469,7 +469,7 @@ function inspectMap(
ctx,
level,
options,
- inspectOptions
+ inspectOptions,
);
}
@@ -510,7 +510,7 @@ function inspectPromise(
value: Promise<unknown>,
ctx: ConsoleContext,
level: number,
- inspectOptions: Required<InspectOptions>
+ inspectOptions: Required<InspectOptions>,
): string {
const [state, result] = Deno.core.getPromiseDetails(value);
@@ -518,15 +518,18 @@ function inspectPromise(
return `Promise { ${cyan("<pending>")} }`;
}
- const prefix =
- state === PromiseState.Fulfilled ? "" : `${red("<rejected>")} `;
+ const prefix = state === PromiseState.Fulfilled
+ ? ""
+ : `${red("<rejected>")} `;
- const str = `${prefix}${inspectValueWithQuotes(
- result,
- ctx,
- level + 1,
- inspectOptions
- )}`;
+ const str = `${prefix}${
+ inspectValueWithQuotes(
+ result,
+ ctx,
+ level + 1,
+ inspectOptions,
+ )
+ }`;
if (str.length + PROMISE_STRING_BASE_LENGTH > LINE_BREAKING_LENGTH) {
return `Promise {\n${DEFAULT_INDENT.repeat(level + 1)}${str}\n}`;
@@ -541,7 +544,7 @@ function inspectRawObject(
value: Record<string, unknown>,
ctx: ConsoleContext,
level: number,
- inspectOptions: Required<InspectOptions>
+ inspectOptions: Required<InspectOptions>,
): string {
if (level >= inspectOptions.depth) {
return cyan("[Object]"); // wrappers are in cyan
@@ -573,28 +576,32 @@ function inspectRawObject(
for (const key of stringKeys) {
entries.push(
- `${key}: ${inspectValueWithQuotes(
- value[key],
- ctx,
- level + 1,
- inspectOptions
- )}`
+ `${key}: ${
+ inspectValueWithQuotes(
+ value[key],
+ ctx,
+ level + 1,
+ inspectOptions,
+ )
+ }`,
);
}
for (const key of symbolKeys) {
entries.push(
- `${key.toString()}: ${inspectValueWithQuotes(
- // eslint-disable-next-line @typescript-eslint/no-explicit-any
- value[key as any],
- ctx,
- level + 1,
- inspectOptions
- )}`
+ `${key.toString()}: ${
+ inspectValueWithQuotes(
+ // eslint-disable-next-line @typescript-eslint/no-explicit-any
+ value[key as any],
+ ctx,
+ level + 1,
+ inspectOptions,
+ )
+ }`,
);
}
// Making sure color codes are ignored when calculating the total length
- const totalLength =
- entries.length + level + stripColor(entries.join("")).length;
+ const totalLength = entries.length + level +
+ stripColor(entries.join("")).length;
ctx.delete(value);
@@ -621,7 +628,7 @@ function inspectObject(
value: {},
consoleContext: ConsoleContext,
level: number,
- inspectOptions: Required<InspectOptions>
+ inspectOptions: Required<InspectOptions>,
): string {
if (customInspect in value && typeof value[customInspect] === "function") {
try {
@@ -658,7 +665,7 @@ function inspectObject(
value,
consoleContext,
level,
- inspectOptions
+ inspectOptions,
);
} else {
// Otherwise, default object formatting
@@ -668,7 +675,7 @@ function inspectObject(
export function inspectArgs(
args: unknown[],
- inspectOptions: InspectOptions = {}
+ inspectOptions: InspectOptions = {},
): string {
const rInspectOptions = { ...DEFAULT_INSPECT_OPTIONS, ...inspectOptions };
const first = args[0];
@@ -717,7 +724,7 @@ export function inspectArgs(
args[++a],
new Set<unknown>(),
0,
- rInspectOptions
+ rInspectOptions,
);
break;
case CHAR_PERCENT:
@@ -808,7 +815,7 @@ export class Console {
inspectArgs(args, {
indentLevel: this.indentLevel,
}) + "\n",
- false
+ false,
);
};
@@ -826,7 +833,7 @@ export class Console {
inspectArgs(args, {
indentLevel: this.indentLevel,
}) + "\n",
- true
+ true,
);
};
@@ -879,7 +886,7 @@ export class Console {
if (properties !== undefined && !Array.isArray(properties)) {
throw new Error(
"The 'properties' argument must be of type Array. " +
- "Received type string"
+ "Received type string",
);
}
@@ -927,8 +934,7 @@ export class Console {
let hasPrimitives = false;
Object.keys(resultData).forEach((k, idx): void => {
const value: unknown = resultData[k]!;
- const primitive =
- value === null ||
+ const primitive = value === null ||
(typeof value !== "function" && typeof value !== "object");
if (properties === undefined && primitive) {
hasPrimitives = true;
@@ -1047,7 +1053,7 @@ export const customInspect = Symbol("Deno.customInspect");
export function inspect(
value: unknown,
- inspectOptions: InspectOptions = {}
+ inspectOptions: InspectOptions = {},
): string {
if (typeof value === "string") {
return value;
diff --git a/cli/js/web/console_table.ts b/cli/js/web/console_table.ts
index ba2d763b7..42667d998 100644
--- a/cli/js/web/console_table.ts
+++ b/cli/js/web/console_table.ts
@@ -28,8 +28,8 @@ function isFullWidthCodePoint(code: number): boolean {
return (
code >= 0x1100 &&
(code <= 0x115f || // Hangul Jamo
- code === 0x2329 || // LEFT-POINTING ANGLE BRACKET
- code === 0x232a || // RIGHT-POINTING ANGLE BRACKET
+ code === 0x2329 || // LEFT-POINTING ANGLE BRACKET
+ code === 0x232a || // RIGHT-POINTING ANGLE BRACKET
// CJK Radicals Supplement .. Enclosed CJK Letters and Months
(code >= 0x2e80 && code <= 0x3247 && code !== 0x303f) ||
// Enclosed CJK Letters and Months .. CJK Unified Ideographs Extension A
@@ -94,7 +94,7 @@ export function cliTable(head: string[], columns: string[][]): string {
const columnWidths = head.map((h: string): number => getStringWidth(h));
const longestColumn = columns.reduce(
(n: number, a: string[]): number => Math.max(n, a.length),
- 0
+ 0,
);
for (let i = 0; i < head.length; i++) {
@@ -114,8 +114,7 @@ export function cliTable(head: string[], columns: string[][]): string {
tableChars.middleMiddle.repeat(i + 2)
);
- let result =
- `${tableChars.topLeft}${divider.join(tableChars.topMiddle)}` +
+ let result = `${tableChars.topLeft}${divider.join(tableChars.topMiddle)}` +
`${tableChars.topRight}\n${renderRow(head, columnWidths)}\n` +
`${tableChars.leftMiddle}${divider.join(tableChars.rowMiddle)}` +
`${tableChars.rightMiddle}\n`;
@@ -124,8 +123,7 @@ export function cliTable(head: string[], columns: string[][]): string {
result += `${renderRow(row, columnWidths)}\n`;
}
- result +=
- `${tableChars.bottomLeft}${divider.join(tableChars.bottomMiddle)}` +
+ result += `${tableChars.bottomLeft}${divider.join(tableChars.bottomMiddle)}` +
tableChars.bottomRight;
return result;
diff --git a/cli/js/web/decode_utf8.ts b/cli/js/web/decode_utf8.ts
index d82634efe..ca190134c 100644
--- a/cli/js/web/decode_utf8.ts
+++ b/cli/js/web/decode_utf8.ts
@@ -31,7 +31,7 @@ declare global {
apply<T, R>(
this: (this: T, ...args: number[]) => R,
thisArg: T,
- args: Uint16Array
+ args: Uint16Array,
): R;
}
}
@@ -39,7 +39,7 @@ declare global {
export function decodeUtf8(
input: Uint8Array,
fatal: boolean,
- ignoreBOM: boolean
+ ignoreBOM: boolean,
): string {
let outString = "";
@@ -61,10 +61,11 @@ export function decodeUtf8(
for (; i < input.length; ++i) {
// Encoding error handling
if (state === 12 || (state !== 0 && (input[i] & 0xc0) !== 0x80)) {
- if (fatal)
+ if (fatal) {
throw new TypeError(
- `Decoder error. Invalid byte in sequence at position ${i} in data.`
+ `Decoder error. Invalid byte in sequence at position ${i} in data.`,
);
+ }
outBuffer[outIndex++] = 0xfffd; // Replacement character
if (outIndex === outBufferLength) {
outString += String.fromCharCode.apply(null, outBuffer);
@@ -73,7 +74,7 @@ export function decodeUtf8(
state = 0;
}
- // prettier-ignore
+ // deno-fmt-ignore
type = [
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0, 0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0, 0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,
@@ -84,11 +85,10 @@ export function decodeUtf8(
8,8,2,2,2,2,2,2,2,2,2,2,2,2,2,2, 2,2,2,2,2,2,2,2,2,2,2,2,2,2,2,2,
10,3,3,3,3,3,3,3,3,3,3,3,3,4,3,3, 11,6,6,6,5,8,8,8,8,8,8,8,8,8,8,8
][input[i]];
- codepoint =
- state !== 0
- ? (input[i] & 0x3f) | (codepoint << 6)
- : (0xff >> type) & input[i];
- // prettier-ignore
+ codepoint = state !== 0
+ ? (input[i] & 0x3f) | (codepoint << 6)
+ : (0xff >> type) & input[i];
+ // deno-fmt-ignore
state = [
0,12,24,36,60,96,84,12,12,12,48,72, 12,12,12,12,12,12,12,12,12,12,12,12,
12, 0,12,12,12,12,12, 0,12, 0,12,12, 12,24,12,12,12,12,12,24,12,24,12,12,
diff --git a/cli/js/web/dom_file.ts b/cli/js/web/dom_file.ts
index 3d65e5768..907337e59 100644
--- a/cli/js/web/dom_file.ts
+++ b/cli/js/web/dom_file.ts
@@ -9,7 +9,7 @@ export class DomFileImpl extends blob.DenoBlob implements File {
constructor(
fileBits: BlobPart[],
fileName: string,
- options?: FilePropertyBag
+ options?: FilePropertyBag,
) {
const { lastModified = Date.now(), ...blobPropertyBag } = options ?? {};
super(fileBits, blobPropertyBag);
diff --git a/cli/js/web/dom_iterable.ts b/cli/js/web/dom_iterable.ts
index 271b2f655..7e26a12a4 100644
--- a/cli/js/web/dom_iterable.ts
+++ b/cli/js/web/dom_iterable.ts
@@ -14,13 +14,13 @@ export interface DomIterable<K, V> {
forEach(
callback: (value: V, key: K, parent: this) => void,
// eslint-disable-next-line @typescript-eslint/no-explicit-any
- thisArg?: any
+ thisArg?: any,
): void;
}
export function DomIterableMixin<K, V, TBase extends Constructor>(
Base: TBase,
- dataSymbol: symbol
+ dataSymbol: symbol,
): TBase & Constructor<DomIterable<K, V>> {
// we have to cast `this` as `any` because there is no way to describe the
// Base class in a way where the Symbol `dataSymbol` is defined. So the
@@ -56,15 +56,15 @@ export function DomIterableMixin<K, V, TBase extends Constructor>(
forEach(
callbackfn: (value: V, key: K, parent: this) => void,
// eslint-disable-next-line @typescript-eslint/no-explicit-any
- thisArg?: any
+ thisArg?: any,
): void {
requiredArguments(
`${this.constructor.name}.forEach`,
arguments.length,
- 1
+ 1,
);
callbackfn = callbackfn.bind(
- thisArg == null ? globalThis : Object(thisArg)
+ thisArg == null ? globalThis : Object(thisArg),
);
// eslint-disable-next-line @typescript-eslint/no-explicit-any
for (const [key, value] of (this as any)[dataSymbol]) {
diff --git a/cli/js/web/dom_types.d.ts b/cli/js/web/dom_types.d.ts
index 5d35c9187..b8636b7d1 100644
--- a/cli/js/web/dom_types.d.ts
+++ b/cli/js/web/dom_types.d.ts
@@ -220,7 +220,7 @@ interface NodeList {
item(index: number): Node | null;
forEach(
callbackfn: (value: Node, key: number, parent: NodeList) => void,
- thisArg?: any
+ thisArg?: any,
): void;
[index: number]: Node;
[Symbol.iterator](): IterableIterator<Node>;
@@ -234,7 +234,7 @@ interface NodeListOf<TNode extends Node> extends NodeList {
item(index: number): TNode;
forEach(
callbackfn: (value: TNode, key: number, parent: NodeListOf<TNode>) => void,
- thisArg?: any
+ thisArg?: any,
): void;
[index: number]: TNode;
[Symbol.iterator](): IterableIterator<TNode>;
diff --git a/cli/js/web/error_event.ts b/cli/js/web/error_event.ts
index 8e7853875..c04a49545 100644
--- a/cli/js/web/error_event.ts
+++ b/cli/js/web/error_event.ts
@@ -39,7 +39,7 @@ export class ErrorEventImpl extends Event implements ErrorEvent {
lineno = 0,
colno = 0,
error = null,
- }: ErrorEventInit = {}
+ }: ErrorEventInit = {},
) {
super(type, {
bubbles: bubbles,
diff --git a/cli/js/web/event.ts b/cli/js/web/event.ts
index 556d403a6..d22d41c29 100644
--- a/cli/js/web/event.ts
+++ b/cli/js/web/event.ts
@@ -53,7 +53,7 @@ export function getStopImmediatePropagation(event: Event): boolean {
export function setCurrentTarget(
event: Event,
- value: EventTarget | null
+ value: EventTarget | null,
): void {
(event as EventImpl).currentTarget = value;
}
@@ -85,7 +85,7 @@ export function setPath(event: Event, value: EventPath[]): void {
export function setRelatedTarget<T extends Event>(
event: T,
- value: EventTarget | null
+ value: EventTarget | null,
): void {
if ("relatedTarget" in event) {
(event as T & {
@@ -100,7 +100,7 @@ export function setTarget(event: Event, value: EventTarget | null): void {
export function setStopImmediatePropagation(
event: Event,
- value: boolean
+ value: boolean,
): void {
const data = eventData.get(event as Event);
if (data) {
@@ -111,7 +111,7 @@ export function setStopImmediatePropagation(
// Type guards that widen the event type
export function hasRelatedTarget(
- event: Event
+ event: Event,
): event is domTypes.FocusEvent | domTypes.MouseEvent {
return "relatedTarget" in event;
}
diff --git a/cli/js/web/event_target.ts b/cli/js/web/event_target.ts
index 6f6897425..82935dd9c 100644
--- a/cli/js/web/event_target.ts
+++ b/cli/js/web/event_target.ts
@@ -46,7 +46,7 @@ function getRoot(eventTarget: EventTarget): EventTarget | null {
}
function isNode<T extends EventTarget>(
- eventTarget: T | null
+ eventTarget: T | null,
): eventTarget is T & domTypes.Node {
return Boolean(eventTarget && "nodeType" in eventTarget);
}
@@ -54,7 +54,7 @@ function isNode<T extends EventTarget>(
// https://dom.spec.whatwg.org/#concept-shadow-including-inclusive-ancestor
function isShadowInclusiveAncestor(
ancestor: EventTarget | null,
- node: EventTarget | null
+ node: EventTarget | null,
): boolean {
while (isNode(node)) {
if (node === ancestor) {
@@ -76,12 +76,12 @@ function isShadowRoot(nodeImpl: EventTarget | null): boolean {
nodeImpl &&
isNode(nodeImpl) &&
nodeImpl.nodeType === DOCUMENT_FRAGMENT_NODE &&
- getHost(nodeImpl) != null
+ getHost(nodeImpl) != null,
);
}
function isSlotable<T extends EventTarget>(
- nodeImpl: T | null
+ nodeImpl: T | null,
): nodeImpl is T & domTypes.Node & domTypes.Slotable {
return Boolean(isNode(nodeImpl) && "assignedSlot" in nodeImpl);
}
@@ -98,7 +98,7 @@ function appendToEventPath(
targetOverride: EventTarget | null,
relatedTarget: EventTarget | null,
touchTargets: EventTarget[],
- slotInClosedTree: boolean
+ slotInClosedTree: boolean,
): void {
const itemInShadowTree = isNode(target) && isShadowRoot(getRoot(target));
const rootOfClosedTree = isShadowRoot(target) && getMode(target) === "closed";
@@ -117,7 +117,7 @@ function appendToEventPath(
function dispatch(
targetImpl: EventTarget,
eventImpl: Event,
- targetOverride?: EventTarget
+ targetOverride?: EventTarget,
): boolean {
let clearTargets = false;
let activationTarget: EventTarget | null = null;
@@ -139,7 +139,7 @@ function dispatch(
targetOverride,
relatedTarget,
touchTargets,
- false
+ false,
);
const isActivationEvent = eventImpl.type === "click";
@@ -149,8 +149,9 @@ function dispatch(
}
let slotInClosedTree = false;
- let slotable =
- isSlotable(targetImpl) && getAssignedSlot(targetImpl) ? targetImpl : null;
+ let slotable = isSlotable(targetImpl) && getAssignedSlot(targetImpl)
+ ? targetImpl
+ : null;
let parent = getParent(targetImpl);
// Populate event path
@@ -181,7 +182,7 @@ function dispatch(
null,
relatedTarget,
touchTargets,
- slotInClosedTree
+ slotInClosedTree,
);
} else if (parent === relatedTarget) {
parent = null;
@@ -202,7 +203,7 @@ function dispatch(
targetImpl,
relatedTarget,
touchTargets,
- slotInClosedTree
+ slotInClosedTree,
);
}
@@ -226,9 +227,8 @@ function dispatch(
}
const clearTargetsTuple = path[clearTargetsTupleIndex];
- clearTargets =
- (isNode(clearTargetsTuple.target) &&
- isShadowRoot(getRoot(clearTargetsTuple.target))) ||
+ clearTargets = (isNode(clearTargetsTuple.target) &&
+ isShadowRoot(getRoot(clearTargetsTuple.target))) ||
(isNode(clearTargetsTuple.relatedTarget) &&
isShadowRoot(getRoot(clearTargetsTuple.relatedTarget)));
@@ -288,7 +288,7 @@ function dispatch(
* Ref: https://dom.spec.whatwg.org/#concept-event-listener-inner-invoke */
function innerInvokeEventListeners(
eventImpl: Event,
- targetListeners: Record<string, Listener[]>
+ targetListeners: Record<string, Listener[]>,
): boolean {
let found = false;
@@ -381,7 +381,7 @@ function invokeEventListeners(tuple: EventPath, eventImpl: Event): void {
}
function normalizeAddEventHandlerOptions(
- options: boolean | AddEventListenerOptions | undefined
+ options: boolean | AddEventListenerOptions | undefined,
): AddEventListenerOptions {
if (typeof options === "boolean" || typeof options === "undefined") {
return {
@@ -395,7 +395,7 @@ function normalizeAddEventHandlerOptions(
}
function normalizeEventHandlerOptions(
- options: boolean | EventListenerOptions | undefined
+ options: boolean | EventListenerOptions | undefined,
): EventListenerOptions {
if (typeof options === "boolean" || typeof options === "undefined") {
return {
@@ -456,7 +456,7 @@ function getAssignedSlot(target: EventTarget): boolean {
function getHasActivationBehavior(target: EventTarget): boolean {
return Boolean(
- eventTargetData.get(target as EventTarget)?.hasActivationBehavior
+ eventTargetData.get(target as EventTarget)?.hasActivationBehavior,
);
}
@@ -490,7 +490,7 @@ export class EventTargetImpl implements EventTarget {
public addEventListener(
type: string,
callback: EventListenerOrEventListenerObject | null,
- options?: AddEventListenerOptions | boolean
+ options?: AddEventListenerOptions | boolean,
): void {
requiredArguments("EventTarget.addEventListener", arguments.length, 2);
if (callback === null) {
@@ -522,14 +522,14 @@ export class EventTargetImpl implements EventTarget {
public removeEventListener(
type: string,
callback: EventListenerOrEventListenerObject | null,
- options?: EventListenerOptions | boolean
+ options?: EventListenerOptions | boolean,
): void {
requiredArguments("EventTarget.removeEventListener", arguments.length, 2);
const listeners = eventTargetData.get(this ?? globalThis)!.listeners;
if (callback !== null && type in listeners) {
listeners[type] = listeners[type].filter(
- (listener) => listener.callback !== callback
+ (listener) => listener.callback !== callback,
);
} else if (callback === null || !listeners[type]) {
return;
diff --git a/cli/js/web/fetch.ts b/cli/js/web/fetch.ts
index d692b83e1..4fe525cde 100644
--- a/cli/js/web/fetch.ts
+++ b/cli/js/web/fetch.ts
@@ -38,14 +38,13 @@ export class Response extends Body.Body implements domTypes.Response {
let status = init.status === undefined ? 200 : Number(init.status || 0);
let statusText = init.statusText ?? "";
- let headers =
- init.headers instanceof Headers
- ? init.headers
- : new Headers(init.headers);
+ let headers = init.headers instanceof Headers
+ ? init.headers
+ : new Headers(init.headers);
if (init.status !== undefined && (status < 200 || status > 599)) {
throw new RangeError(
- `The status provided (${init.status}) is outside the range [200, 599]`
+ `The status provided (${init.status}) is outside the range [200, 599]`,
);
}
@@ -156,7 +155,7 @@ export class Response extends Body.Body implements domTypes.Response {
static redirect(url: URL | string, status: number): domTypes.Response {
if (![301, 302, 303, 307, 308].includes(status)) {
throw new RangeError(
- "The redirection status must be one of 301, 302, 303, 307 and 308."
+ "The redirection status must be one of 301, 302, 303, 307 and 308.",
);
}
return new Response(null, {
@@ -171,7 +170,7 @@ function sendFetchReq(
url: string,
method: string | null,
headers: Headers | null,
- body: ArrayBufferView | undefined
+ body: ArrayBufferView | undefined,
): Promise<FetchResponse> {
let headerArray: Array<[string, string]> = [];
if (headers) {
@@ -189,7 +188,7 @@ function sendFetchReq(
export async function fetch(
input: (domTypes.Request & { _bodySource?: unknown }) | URL | string,
- init?: domTypes.RequestInit
+ init?: domTypes.RequestInit,
): Promise<Response> {
let url: string;
let method: string | null = null;
@@ -203,10 +202,9 @@ export async function fetch(
if (init != null) {
method = init.method || null;
if (init.headers) {
- headers =
- init.headers instanceof Headers
- ? init.headers
- : new Headers(init.headers);
+ headers = init.headers instanceof Headers
+ ? init.headers
+ : new Headers(init.headers);
} else {
headers = null;
}
diff --git a/cli/js/web/fetch/multipart.ts b/cli/js/web/fetch/multipart.ts
index a632d8600..f30975e5e 100644
--- a/cli/js/web/fetch/multipart.ts
+++ b/cli/js/web/fetch/multipart.ts
@@ -64,7 +64,7 @@ export class MultipartBuilder {
#writeFileHeaders = (
field: string,
filename: string,
- type?: string
+ type?: string,
): void => {
const headers = [
[
@@ -122,7 +122,7 @@ export class MultipartParser {
return {
headers,
disposition: getHeaderValueParams(
- headers.get("Content-Disposition") ?? ""
+ headers.get("Content-Disposition") ?? "",
),
};
};
diff --git a/cli/js/web/form_data.ts b/cli/js/web/form_data.ts
index 2566943f0..1a0622638 100644
--- a/cli/js/web/form_data.ts
+++ b/cli/js/web/form_data.ts
@@ -16,7 +16,7 @@ class FormDataBase {
append(
name: string,
value: string | blob.DenoBlob | domFile.DomFileImpl,
- filename?: string
+ filename?: string,
): void {
requiredArguments("FormData.append", arguments.length, 2);
name = String(name);
@@ -82,7 +82,7 @@ class FormDataBase {
set(
name: string,
value: string | blob.DenoBlob | domFile.DomFileImpl,
- filename?: string
+ filename?: string,
): void {
requiredArguments("FormData.set", arguments.length, 2);
name = String(name);
@@ -102,7 +102,7 @@ class FormDataBase {
filename || "blob",
{
type: value.type,
- }
+ },
);
} else {
this[dataSymbol][i][1] = String(value);
diff --git a/cli/js/web/headers.ts b/cli/js/web/headers.ts
index 5fd6abc44..d75f87adc 100644
--- a/cli/js/web/headers.ts
+++ b/cli/js/web/headers.ts
@@ -55,7 +55,7 @@ function validateValue(value: string): void {
function dataAppend(
data: Array<[string, string]>,
key: string,
- value: string
+ value: string,
): void {
for (let i = 0; i < data.length; i++) {
const [dataKey] = data[i];
@@ -85,7 +85,7 @@ function dataAppend(
* entry in the headers list. */
function dataGet(
data: Array<[string, string]>,
- key: string
+ key: string,
): string | undefined {
const setCookieValues = [];
for (const [dataKey, value] of data) {
@@ -118,7 +118,7 @@ function dataGet(
function dataSet(
data: Array<[string, string]>,
key: string,
- value: string
+ value: string,
): void {
for (let i = 0; i < data.length; i++) {
const [dataKey] = data[i];
@@ -169,7 +169,7 @@ class HeadersBase {
constructor(init?: HeadersInit) {
if (init === null) {
throw new TypeError(
- "Failed to construct 'Headers'; The provided value was not valid"
+ "Failed to construct 'Headers'; The provided value was not valid",
);
} else if (isHeaders(init)) {
this[headersData] = [...init];
@@ -183,7 +183,7 @@ class HeadersBase {
requiredArguments(
"Headers.constructor tuple array argument",
tuple.length,
- 2
+ 2,
);
this.append(tuple[0], tuple[1]);
diff --git a/cli/js/web/performance.ts b/cli/js/web/performance.ts
index eb0479b37..1acff9f75 100644
--- a/cli/js/web/performance.ts
+++ b/cli/js/web/performance.ts
@@ -8,7 +8,7 @@ let performanceEntries: PerformanceEntryList = [];
function findMostRecent(
name: string,
- type: "mark" | "measure"
+ type: "mark" | "measure",
): PerformanceEntry | undefined {
return performanceEntries
.slice()
@@ -32,12 +32,12 @@ function convertMarkToTimestamp(mark: string | number): number {
function filterByNameType(
name?: string,
- type?: "mark" | "measure"
+ type?: "mark" | "measure",
): PerformanceEntryList {
return performanceEntries.filter(
(entry) =>
(name ? entry.name === name : true) &&
- (type ? entry.entryType === type : true)
+ (type ? entry.entryType === type : true),
);
}
@@ -72,7 +72,7 @@ export class PerformanceEntryImpl implements PerformanceEntry {
name: string,
entryType: string,
startTime: number,
- duration: number
+ duration: number,
) {
this.#name = name;
this.#entryType = entryType;
@@ -111,7 +111,7 @@ export class PerformanceMarkImpl extends PerformanceEntryImpl
constructor(
name: string,
- { detail = null, startTime = now() }: PerformanceMarkOptions = {}
+ { detail = null, startTime = now() }: PerformanceMarkOptions = {},
) {
super(name, "mark", startTime, 0);
if (startTime < 0) {
@@ -133,11 +133,9 @@ export class PerformanceMarkImpl extends PerformanceEntryImpl
[customInspect](): string {
return this.detail
- ? `${this.constructor.name} {\n detail: ${inspect(this.detail, {
- depth: 3,
- })},\n name: "${this.name}",\n entryType: "${
- this.entryType
- }",\n startTime: ${this.startTime},\n duration: ${this.duration}\n}`
+ ? `${this.constructor.name} {\n detail: ${
+ inspect(this.detail, { depth: 3 })
+ },\n name: "${this.name}",\n entryType: "${this.entryType}",\n startTime: ${this.startTime},\n duration: ${this.duration}\n}`
: `${this.constructor.name} { detail: ${this.detail}, name: "${this.name}", entryType: "${this.entryType}", startTime: ${this.startTime}, duration: ${this.duration} }`;
}
}
@@ -161,7 +159,7 @@ export class PerformanceMeasureImpl extends PerformanceEntryImpl
startTime: number,
duration: number,
// eslint-disable-next-line @typescript-eslint/no-explicit-any
- detail: any = null
+ detail: any = null,
) {
super(name, "measure", startTime, duration);
this.#detail = cloneValue(detail);
@@ -180,11 +178,9 @@ export class PerformanceMeasureImpl extends PerformanceEntryImpl
[customInspect](): string {
return this.detail
- ? `${this.constructor.name} {\n detail: ${inspect(this.detail, {
- depth: 3,
- })},\n name: "${this.name}",\n entryType: "${
- this.entryType
- }",\n startTime: ${this.startTime},\n duration: ${this.duration}\n}`
+ ? `${this.constructor.name} {\n detail: ${
+ inspect(this.detail, { depth: 3 })
+ },\n name: "${this.name}",\n entryType: "${this.entryType}",\n startTime: ${this.startTime},\n duration: ${this.duration}\n}`
: `${this.constructor.name} { detail: ${this.detail}, name: "${this.name}", entryType: "${this.entryType}", startTime: ${this.startTime}, duration: ${this.duration} }`;
}
}
@@ -193,11 +189,11 @@ export class PerformanceImpl implements Performance {
clearMarks(markName?: string): void {
if (markName == null) {
performanceEntries = performanceEntries.filter(
- (entry) => entry.entryType !== "mark"
+ (entry) => entry.entryType !== "mark",
);
} else {
performanceEntries = performanceEntries.filter(
- (entry) => !(entry.name === markName && entry.entryType === "mark")
+ (entry) => !(entry.name === markName && entry.entryType === "mark"),
);
}
}
@@ -205,12 +201,12 @@ export class PerformanceImpl implements Performance {
clearMeasures(measureName?: string): void {
if (measureName == null) {
performanceEntries = performanceEntries.filter(
- (entry) => entry.entryType !== "measure"
+ (entry) => entry.entryType !== "measure",
);
} else {
performanceEntries = performanceEntries.filter(
(entry) =>
- !(entry.name === measureName && entry.entryType === "measure")
+ !(entry.name === measureName && entry.entryType === "measure"),
);
}
}
@@ -220,7 +216,7 @@ export class PerformanceImpl implements Performance {
}
getEntriesByName(
name: string,
- type?: "mark" | "measure"
+ type?: "mark" | "measure",
): PerformanceEntryList {
return filterByNameType(name, type);
}
@@ -230,7 +226,7 @@ export class PerformanceImpl implements Performance {
mark(
markName: string,
- options: PerformanceMarkOptions = {}
+ options: PerformanceMarkOptions = {},
): PerformanceMark {
// 3.1.1.1 If the global object is a Window object and markName uses the
// same name as a read only attribute in the PerformanceTiming interface,
@@ -243,17 +239,17 @@ export class PerformanceImpl implements Performance {
measure(
measureName: string,
- options?: PerformanceMeasureOptions
+ options?: PerformanceMeasureOptions,
): PerformanceMeasure;
measure(
measureName: string,
startMark?: string,
- endMark?: string
+ endMark?: string,
): PerformanceMeasure;
measure(
measureName: string,
startOrMeasureOptions: string | PerformanceMeasureOptions = {},
- endMark?: string
+ endMark?: string,
): PerformanceMeasure {
if (startOrMeasureOptions && typeof startOrMeasureOptions === "object") {
if (endMark) {
@@ -271,7 +267,7 @@ export class PerformanceImpl implements Performance {
"end" in startOrMeasureOptions
) {
throw new TypeError(
- "Cannot specify start, end, and duration together in options."
+ "Cannot specify start, end, and duration together in options.",
);
}
}
@@ -319,7 +315,7 @@ export class PerformanceImpl implements Performance {
endTime - startTime,
typeof startOrMeasureOptions === "object"
? startOrMeasureOptions.detail ?? null
- : null
+ : null,
);
performanceEntries.push(entry);
return entry;
diff --git a/cli/js/web/streams/internals.ts b/cli/js/web/streams/internals.ts
index 58a62e3cb..06c5e304d 100644
--- a/cli/js/web/streams/internals.ts
+++ b/cli/js/web/streams/internals.ts
@@ -66,7 +66,7 @@ export interface ReadableStreamAsyncIterator<T = any> extends AsyncIterator<T> {
export function acquireReadableStreamDefaultReader<T>(
stream: ReadableStreamImpl<T>,
- forAuthorCode = false
+ forAuthorCode = false,
): ReadableStreamDefaultReaderImpl<T> {
const reader = new ReadableStreamDefaultReaderImpl(stream);
reader[sym.forAuthorCode] = forAuthorCode;
@@ -74,7 +74,7 @@ export function acquireReadableStreamDefaultReader<T>(
}
export function acquireWritableStreamDefaultWriter<W>(
- stream: WritableStreamImpl<W>
+ stream: WritableStreamImpl<W>,
): WritableStreamDefaultWriterImpl<W> {
return new WritableStreamDefaultWriterImpl(stream);
}
@@ -82,14 +82,14 @@ export function acquireWritableStreamDefaultWriter<W>(
export function call<F extends (...args: any[]) => any>(
fn: F,
v: ThisType<F>,
- args: Parameters<F>
+ args: Parameters<F>,
): ReturnType<F> {
return Function.prototype.apply.call(fn, v, args);
}
function createAlgorithmFromUnderlyingMethod<
O extends UnderlyingByteSource | UnderlyingSource | Transformer,
- P extends keyof O
+ P extends keyof O,
>(
underlyingObject: O,
methodName: P,
@@ -99,7 +99,7 @@ function createAlgorithmFromUnderlyingMethod<
function createAlgorithmFromUnderlyingMethod<
O extends UnderlyingByteSource | UnderlyingSource | Transformer,
- P extends keyof O
+ P extends keyof O,
>(
underlyingObject: O,
methodName: P,
@@ -108,7 +108,7 @@ function createAlgorithmFromUnderlyingMethod<
): (arg: any) => Promise<void>;
function createAlgorithmFromUnderlyingMethod<
O extends UnderlyingByteSource | UnderlyingSource | Transformer,
- P extends keyof O
+ P extends keyof O,
>(
underlyingObject: O,
methodName: P,
@@ -138,15 +138,15 @@ function createReadableStream<T>(
pullAlgorithm: PullAlgorithm,
cancelAlgorithm: CancelAlgorithm,
highWaterMark = 1,
- sizeAlgorithm: SizeAlgorithm<T> = (): number => 1
+ sizeAlgorithm: SizeAlgorithm<T> = (): number => 1,
): ReadableStreamImpl<T> {
highWaterMark = validateAndNormalizeHighWaterMark(highWaterMark);
const stream: ReadableStreamImpl<T> = Object.create(
- ReadableStreamImpl.prototype
+ ReadableStreamImpl.prototype,
);
initializeReadableStream(stream);
const controller: ReadableStreamDefaultControllerImpl<T> = Object.create(
- ReadableStreamDefaultControllerImpl.prototype
+ ReadableStreamDefaultControllerImpl.prototype,
);
setUpReadableStreamDefaultController(
stream,
@@ -155,7 +155,7 @@ function createReadableStream<T>(
pullAlgorithm,
cancelAlgorithm,
highWaterMark,
- sizeAlgorithm
+ sizeAlgorithm,
);
return stream;
}
@@ -166,13 +166,13 @@ function createWritableStream<W>(
closeAlgorithm: CloseAlgorithm,
abortAlgorithm: AbortAlgorithm,
highWaterMark = 1,
- sizeAlgorithm: SizeAlgorithm<W> = (): number => 1
+ sizeAlgorithm: SizeAlgorithm<W> = (): number => 1,
): WritableStreamImpl<W> {
highWaterMark = validateAndNormalizeHighWaterMark(highWaterMark);
const stream = Object.create(WritableStreamImpl.prototype);
initializeWritableStream(stream);
const controller = Object.create(
- WritableStreamDefaultControllerImpl.prototype
+ WritableStreamDefaultControllerImpl.prototype,
);
setUpWritableStreamDefaultController(
stream,
@@ -182,7 +182,7 @@ function createWritableStream<W>(
closeAlgorithm,
abortAlgorithm,
highWaterMark,
- sizeAlgorithm
+ sizeAlgorithm,
);
return stream;
}
@@ -201,7 +201,7 @@ export function dequeueValue<R>(container: Container<R>): R {
function enqueueValueWithSize<R>(
container: Container<R>,
value: R,
- size: number
+ size: number,
): void {
assert(sym.queue in container && sym.queueTotalSize in container);
size = Number(size);
@@ -225,7 +225,7 @@ export function getDeferred<T>(): Required<Deferred<T>> {
}
export function initializeReadableStream<R>(
- stream: ReadableStreamImpl<R>
+ stream: ReadableStreamImpl<R>,
): void {
stream[sym.state] = "readable";
stream[sym.reader] = stream[sym.storedError] = undefined;
@@ -238,7 +238,7 @@ export function initializeTransformStream<I, O>(
writableHighWaterMark: number,
writableSizeAlgorithm: SizeAlgorithm<I>,
readableHighWaterMark: number,
- readableSizeAlgorithm: SizeAlgorithm<O>
+ readableSizeAlgorithm: SizeAlgorithm<O>,
): void {
const startAlgorithm = (): Promise<void> => startPromise;
const writeAlgorithm = (chunk: any): Promise<void> =>
@@ -253,7 +253,7 @@ export function initializeTransformStream<I, O>(
closeAlgorithm,
abortAlgorithm,
writableHighWaterMark,
- writableSizeAlgorithm
+ writableSizeAlgorithm,
);
const pullAlgorithm = (): PromiseLike<void> =>
transformStreamDefaultSourcePullAlgorithm(stream);
@@ -266,7 +266,7 @@ export function initializeTransformStream<I, O>(
pullAlgorithm,
cancelAlgorithm,
readableHighWaterMark,
- readableSizeAlgorithm
+ readableSizeAlgorithm,
);
stream[sym.backpressure] = stream[sym.backpressureChangePromise] = undefined;
transformStreamSetBackpressure(stream, true);
@@ -277,7 +277,7 @@ export function initializeTransformStream<I, O>(
}
export function initializeWritableStream<W>(
- stream: WritableStreamImpl<W>
+ stream: WritableStreamImpl<W>,
): void {
stream[sym.state] = "writable";
stream[sym.storedError] = stream[sym.writer] = stream[
@@ -315,7 +315,7 @@ function isFiniteNonNegativeNumber(v: unknown): v is number {
}
export function isReadableByteStreamController(
- x: unknown
+ x: unknown,
): x is ReadableByteStreamControllerImpl {
return !(
typeof x !== "object" ||
@@ -333,7 +333,7 @@ export function isReadableStream(x: unknown): x is ReadableStreamImpl {
}
export function isReadableStreamAsyncIterator(
- x: unknown
+ x: unknown,
): x is ReadableStreamAsyncIterator {
if (typeof x !== "object" || x === null) {
return false;
@@ -342,7 +342,7 @@ export function isReadableStreamAsyncIterator(
}
export function isReadableStreamDefaultController(
- x: unknown
+ x: unknown,
): x is ReadableStreamDefaultControllerImpl {
return !(
typeof x !== "object" ||
@@ -352,7 +352,7 @@ export function isReadableStreamDefaultController(
}
export function isReadableStreamDefaultReader<T>(
- x: unknown
+ x: unknown,
): x is ReadableStreamDefaultReaderImpl<T> {
return !(typeof x !== "object" || x === null || !(sym.readRequests in x));
}
@@ -376,7 +376,7 @@ export function isTransformStream(x: unknown): x is TransformStreamImpl {
}
export function isTransformStreamDefaultController(
- x: unknown
+ x: unknown,
): x is TransformStreamDefaultControllerImpl {
return !(
typeof x !== "object" ||
@@ -386,7 +386,7 @@ export function isTransformStreamDefaultController(
}
export function isUnderlyingByteSource(
- underlyingSource: UnderlyingByteSource | UnderlyingSource
+ underlyingSource: UnderlyingByteSource | UnderlyingSource,
): underlyingSource is UnderlyingByteSource {
const { type } = underlyingSource;
const typeString = String(type);
@@ -402,7 +402,7 @@ export function isWritableStream(x: unknown): x is WritableStreamImpl {
}
export function isWritableStreamDefaultController(
- x: unknown
+ x: unknown,
): x is WritableStreamDefaultControllerImpl<any> {
return !(
typeof x !== "object" ||
@@ -412,7 +412,7 @@ export function isWritableStreamDefaultController(
}
export function isWritableStreamDefaultWriter(
- x: unknown
+ x: unknown,
): x is WritableStreamDefaultWriterImpl<any> {
return !(
typeof x !== "object" ||
@@ -427,7 +427,7 @@ export function isWritableStreamLocked(stream: WritableStreamImpl): boolean {
}
export function makeSizeAlgorithmFromSizeFunction<T>(
- size: QueuingStrategySizeCallback<T> | undefined
+ size: QueuingStrategySizeCallback<T> | undefined,
): SizeAlgorithm<T> {
if (size === undefined) {
return (): number => 1;
@@ -448,7 +448,7 @@ function peekQueueValue<T>(container: Container<T>): T | "close" {
}
function readableByteStreamControllerShouldCallPull(
- controller: ReadableByteStreamControllerImpl
+ controller: ReadableByteStreamControllerImpl,
): boolean {
const stream = controller[sym.controlledReadableByteStream];
if (
@@ -472,7 +472,7 @@ function readableByteStreamControllerShouldCallPull(
}
export function readableByteStreamControllerCallPullIfNeeded(
- controller: ReadableByteStreamControllerImpl
+ controller: ReadableByteStreamControllerImpl,
): void {
const shouldPull = readableByteStreamControllerShouldCallPull(controller);
if (!shouldPull) {
@@ -496,20 +496,20 @@ export function readableByteStreamControllerCallPullIfNeeded(
},
(e) => {
readableByteStreamControllerError(controller, e);
- }
- )
+ },
+ ),
);
}
export function readableByteStreamControllerClearAlgorithms(
- controller: ReadableByteStreamControllerImpl
+ controller: ReadableByteStreamControllerImpl,
): void {
(controller as any)[sym.pullAlgorithm] = undefined;
(controller as any)[sym.cancelAlgorithm] = undefined;
}
export function readableByteStreamControllerClose(
- controller: ReadableByteStreamControllerImpl
+ controller: ReadableByteStreamControllerImpl,
): void {
const stream = controller[sym.controlledReadableByteStream];
if (controller[sym.closeRequested] || stream[sym.state] !== "readable") {
@@ -526,7 +526,7 @@ export function readableByteStreamControllerClose(
export function readableByteStreamControllerEnqueue(
controller: ReadableByteStreamControllerImpl,
- chunk: ArrayBufferView
+ chunk: ArrayBufferView,
): void {
const stream = controller[sym.controlledReadableByteStream];
if (controller[sym.closeRequested] || stream[sym.state] !== "readable") {
@@ -540,14 +540,14 @@ export function readableByteStreamControllerEnqueue(
controller,
transferredBuffer,
byteOffset,
- byteLength
+ byteLength,
);
} else {
assert(controller[sym.queue].length === 0);
const transferredView = new Uint8Array(
transferredBuffer,
byteOffset,
- byteLength
+ byteLength,
);
readableStreamFulfillReadRequest(stream, transferredView, false);
}
@@ -558,7 +558,7 @@ export function readableByteStreamControllerEnqueue(
controller,
transferredBuffer,
byteOffset,
- byteLength
+ byteLength,
);
}
readableByteStreamControllerCallPullIfNeeded(controller);
@@ -568,7 +568,7 @@ function readableByteStreamControllerEnqueueChunkToQueue(
controller: ReadableByteStreamControllerImpl,
buffer: ArrayBuffer | SharedArrayBuffer,
byteOffset: number,
- byteLength: number
+ byteLength: number,
): void {
controller[sym.queue].push({
value: buffer,
@@ -580,7 +580,7 @@ function readableByteStreamControllerEnqueueChunkToQueue(
export function readableByteStreamControllerError(
controller: ReadableByteStreamControllerImpl,
- e: any
+ e: any,
): void {
const stream = controller[sym.controlledReadableByteStream];
if (stream[sym.state] !== "readable") {
@@ -593,7 +593,7 @@ export function readableByteStreamControllerError(
}
export function readableByteStreamControllerGetDesiredSize(
- controller: ReadableByteStreamControllerImpl
+ controller: ReadableByteStreamControllerImpl,
): number | null {
const stream = controller[sym.controlledReadableByteStream];
const state = stream[sym.state];
@@ -607,10 +607,10 @@ export function readableByteStreamControllerGetDesiredSize(
}
export function readableByteStreamControllerHandleQueueDrain(
- controller: ReadableByteStreamControllerImpl
+ controller: ReadableByteStreamControllerImpl,
): void {
assert(
- controller[sym.controlledReadableByteStream][sym.state] === "readable"
+ controller[sym.controlledReadableByteStream][sym.state] === "readable",
);
if (controller[sym.queueTotalSize] === 0 && controller[sym.closeRequested]) {
readableByteStreamControllerClearAlgorithms(controller);
@@ -621,7 +621,7 @@ export function readableByteStreamControllerHandleQueueDrain(
}
export function readableStreamAddReadRequest<R>(
- stream: ReadableStreamImpl<R>
+ stream: ReadableStreamImpl<R>,
): Promise<ReadableStreamReadResult<R>> {
assert(isReadableStreamDefaultReader(stream[sym.reader]));
assert(stream[sym.state] === "readable");
@@ -632,7 +632,7 @@ export function readableStreamAddReadRequest<R>(
export function readableStreamCancel<T>(
stream: ReadableStreamImpl<T>,
- reason: any
+ reason: any,
): Promise<void> {
stream[sym.disturbed] = true;
if (stream[sym.state] === "closed") {
@@ -643,7 +643,7 @@ export function readableStreamCancel<T>(
}
readableStreamClose(stream);
return stream[sym.readableStreamController]![sym.cancelSteps](reason).then(
- () => undefined
+ () => undefined,
) as Promise<void>;
}
@@ -661,8 +661,8 @@ export function readableStreamClose<T>(stream: ReadableStreamImpl<T>): void {
readableStreamCreateReadResult<T>(
undefined,
true,
- reader[sym.forAuthorCode]
- )
+ reader[sym.forAuthorCode],
+ ),
);
}
reader[sym.readRequests] = [];
@@ -675,7 +675,7 @@ export function readableStreamClose<T>(stream: ReadableStreamImpl<T>): void {
export function readableStreamCreateReadResult<T>(
value: T | undefined,
done: boolean,
- forAuthorCode: boolean
+ forAuthorCode: boolean,
): ReadableStreamReadResult<T> {
const prototype = forAuthorCode ? Object.prototype : null;
assert(typeof done === "boolean");
@@ -688,7 +688,7 @@ export function readableStreamCreateReadResult<T>(
}
export function readableStreamDefaultControllerCallPullIfNeeded<T>(
- controller: ReadableStreamDefaultControllerImpl<T>
+ controller: ReadableStreamDefaultControllerImpl<T>,
): void {
const shouldPull = readableStreamDefaultControllerShouldCallPull(controller);
if (!shouldPull) {
@@ -711,19 +711,19 @@ export function readableStreamDefaultControllerCallPullIfNeeded<T>(
},
(e) => {
readableStreamDefaultControllerError(controller, e);
- }
+ },
);
}
export function readableStreamDefaultControllerCanCloseOrEnqueue<T>(
- controller: ReadableStreamDefaultControllerImpl<T>
+ controller: ReadableStreamDefaultControllerImpl<T>,
): boolean {
const state = controller[sym.controlledReadableStream][sym.state];
return !controller[sym.closeRequested] && state === "readable";
}
export function readableStreamDefaultControllerClearAlgorithms<T>(
- controller: ReadableStreamDefaultControllerImpl<T>
+ controller: ReadableStreamDefaultControllerImpl<T>,
): void {
(controller as any)[sym.pullAlgorithm] = undefined;
(controller as any)[sym.cancelAlgorithm] = undefined;
@@ -731,7 +731,7 @@ export function readableStreamDefaultControllerClearAlgorithms<T>(
}
export function readableStreamDefaultControllerClose<T>(
- controller: ReadableStreamDefaultControllerImpl<T>
+ controller: ReadableStreamDefaultControllerImpl<T>,
): void {
if (!readableStreamDefaultControllerCanCloseOrEnqueue(controller)) {
return;
@@ -746,7 +746,7 @@ export function readableStreamDefaultControllerClose<T>(
export function readableStreamDefaultControllerEnqueue<T>(
controller: ReadableStreamDefaultControllerImpl<T>,
- chunk: T
+ chunk: T,
): void {
if (!readableStreamDefaultControllerCanCloseOrEnqueue(controller)) {
return;
@@ -770,7 +770,7 @@ export function readableStreamDefaultControllerEnqueue<T>(
}
export function readableStreamDefaultControllerGetDesiredSize<T>(
- controller: ReadableStreamDefaultControllerImpl<T>
+ controller: ReadableStreamDefaultControllerImpl<T>,
): number | null {
const stream = controller[sym.controlledReadableStream];
const state = stream[sym.state];
@@ -785,7 +785,7 @@ export function readableStreamDefaultControllerGetDesiredSize<T>(
export function readableStreamDefaultControllerError<T>(
controller: ReadableStreamDefaultControllerImpl<T>,
- e: any
+ e: any,
): void {
const stream = controller[sym.controlledReadableStream];
if (stream[sym.state] !== "readable") {
@@ -797,13 +797,13 @@ export function readableStreamDefaultControllerError<T>(
}
function readableStreamDefaultControllerHasBackpressure<T>(
- controller: ReadableStreamDefaultControllerImpl<T>
+ controller: ReadableStreamDefaultControllerImpl<T>,
): boolean {
return readableStreamDefaultControllerShouldCallPull(controller);
}
function readableStreamDefaultControllerShouldCallPull<T>(
- controller: ReadableStreamDefaultControllerImpl<T>
+ controller: ReadableStreamDefaultControllerImpl<T>,
): boolean {
const stream = controller[sym.controlledReadableStream];
if (
@@ -824,7 +824,7 @@ function readableStreamDefaultControllerShouldCallPull<T>(
}
export function readableStreamDefaultReaderRead<R>(
- reader: ReadableStreamDefaultReaderImpl<R>
+ reader: ReadableStreamDefaultReaderImpl<R>,
): Promise<ReadableStreamReadResult<R>> {
const stream = reader[sym.ownerReadableStream];
assert(stream);
@@ -834,8 +834,8 @@ export function readableStreamDefaultReaderRead<R>(
readableStreamCreateReadResult<R>(
undefined,
true,
- reader[sym.forAuthorCode]
- )
+ reader[sym.forAuthorCode],
+ ),
);
}
if (stream[sym.state] === "errored") {
@@ -875,24 +875,24 @@ export function readableStreamError(stream: ReadableStreamImpl, e: any): void {
export function readableStreamFulfillReadRequest<R>(
stream: ReadableStreamImpl<R>,
chunk: R,
- done: boolean
+ done: boolean,
): void {
const reader = stream[sym.reader]!;
const readRequest = reader[sym.readRequests].shift()!;
assert(readRequest.resolve);
readRequest.resolve(
- readableStreamCreateReadResult(chunk, done, reader[sym.forAuthorCode])
+ readableStreamCreateReadResult(chunk, done, reader[sym.forAuthorCode]),
);
}
export function readableStreamGetNumReadRequests(
- stream: ReadableStreamImpl
+ stream: ReadableStreamImpl,
): number {
return stream[sym.reader]?.[sym.readRequests].length ?? 0;
}
export function readableStreamHasDefaultReader(
- stream: ReadableStreamImpl
+ stream: ReadableStreamImpl,
): boolean {
const reader = stream[sym.reader];
return !(reader === undefined || !isReadableStreamDefaultReader(reader));
@@ -904,14 +904,14 @@ export function readableStreamPipeTo<T>(
preventClose: boolean,
preventAbort: boolean,
preventCancel: boolean,
- signal: AbortSignalImpl | undefined
+ signal: AbortSignalImpl | undefined,
): Promise<void> {
assert(isReadableStream(source));
assert(isWritableStream(dest));
assert(
typeof preventClose === "boolean" &&
typeof preventAbort === "boolean" &&
- typeof preventCancel === "boolean"
+ typeof preventCancel === "boolean",
);
assert(signal === undefined || signal instanceof AbortSignalImpl);
assert(!isReadableStreamLocked(source));
@@ -947,7 +947,7 @@ export function readableStreamPipeTo<T>(
shutdownWithAction(
() => Promise.all(actions.map((action) => action())),
true,
- error
+ error,
);
};
if (signal.aborted) {
@@ -967,7 +967,7 @@ export function readableStreamPipeTo<T>(
function isOrBecomesClosed(
stream: ReadableStreamImpl | WritableStreamImpl,
promise: Promise<void>,
- action: () => void
+ action: () => void,
): void {
if (stream[sym.state] === "closed") {
action();
@@ -979,7 +979,7 @@ export function readableStreamPipeTo<T>(
function isOrBecomesErrored(
stream: ReadableStreamImpl | WritableStreamImpl,
promise: Promise<void>,
- action: (error: any) => void
+ action: (error: any) => void,
): void {
if (stream[sym.state] === "errored") {
action(stream[sym.storedError]);
@@ -1012,14 +1012,14 @@ export function readableStreamPipeTo<T>(
function shutdownWithAction(
action: () => Promise<any>,
originalIsError?: boolean,
- originalError?: any
+ originalError?: any,
): void {
function doTheRest(): void {
setPromiseIsHandledToTrue(
action().then(
() => finalize(originalIsError, originalError),
- (newError) => finalize(true, newError)
- )
+ (newError) => finalize(true, newError),
+ ),
);
}
@@ -1049,7 +1049,7 @@ export function readableStreamPipeTo<T>(
!writableStreamCloseQueuedOrInFlight(dest)
) {
setPromiseIsHandledToTrue(
- waitForWritesToFinish().then(() => finalize(isError, error))
+ waitForWritesToFinish().then(() => finalize(isError, error)),
);
}
finalize(isError, error);
@@ -1066,7 +1066,7 @@ export function readableStreamPipeTo<T>(
}
currentWrite = writableStreamDefaultWriterWrite(
writer,
- value!
+ value!,
).then(undefined, () => {});
return false;
});
@@ -1094,12 +1094,12 @@ export function readableStreamPipeTo<T>(
shutdownWithAction(
() => writableStreamAbort(dest, storedError),
true,
- storedError
+ storedError,
);
} else {
shutdown(true, storedError);
}
- }
+ },
);
isOrBecomesErrored(dest, writer[sym.closedPromise].promise, (storedError) => {
@@ -1107,7 +1107,7 @@ export function readableStreamPipeTo<T>(
shutdownWithAction(
() => readableStreamCancel(source, storedError),
true,
- storedError
+ storedError,
);
} else {
shutdown(true, storedError);
@@ -1127,13 +1127,13 @@ export function readableStreamPipeTo<T>(
dest[sym.state] === "closed"
) {
const destClosed = new TypeError(
- "The destination writable stream closed before all data could be piped to it."
+ "The destination writable stream closed before all data could be piped to it.",
);
if (!preventCancel) {
shutdownWithAction(
() => readableStreamCancel(source, destClosed),
true,
- destClosed
+ destClosed,
);
} else {
shutdown(true, destClosed);
@@ -1146,7 +1146,7 @@ export function readableStreamPipeTo<T>(
export function readableStreamReaderGenericCancel<R = any>(
reader: ReadableStreamGenericReader<R>,
- reason: any
+ reason: any,
): Promise<void> {
const stream = reader[sym.ownerReadableStream];
assert(stream);
@@ -1155,7 +1155,7 @@ export function readableStreamReaderGenericCancel<R = any>(
export function readableStreamReaderGenericInitialize<R = any>(
reader: ReadableStreamGenericReader<R>,
- stream: ReadableStreamImpl<R>
+ stream: ReadableStreamImpl<R>,
): void {
reader[sym.forAuthorCode] = true;
reader[sym.ownerReadableStream] = stream;
@@ -1174,7 +1174,7 @@ export function readableStreamReaderGenericInitialize<R = any>(
}
export function readableStreamReaderGenericRelease<R = any>(
- reader: ReadableStreamGenericReader<R>
+ reader: ReadableStreamGenericReader<R>,
): void {
assert(reader[sym.ownerReadableStream]);
assert(reader[sym.ownerReadableStream][sym.reader] === reader);
@@ -1194,7 +1194,7 @@ export function readableStreamReaderGenericRelease<R = any>(
export function readableStreamTee<T>(
stream: ReadableStreamImpl<T>,
- cloneForBranch2: boolean
+ cloneForBranch2: boolean,
): [ReadableStreamImpl<T>, ReadableStreamImpl<T>] {
assert(isReadableStream(stream));
assert(typeof cloneForBranch2 === "boolean");
@@ -1225,14 +1225,14 @@ export function readableStreamTee<T>(
readableStreamDefaultControllerClose(
branch1[
sym.readableStreamController
- ] as ReadableStreamDefaultControllerImpl
+ ] as ReadableStreamDefaultControllerImpl,
);
}
if (!canceled2) {
readableStreamDefaultControllerClose(
branch2[
sym.readableStreamController
- ] as ReadableStreamDefaultControllerImpl
+ ] as ReadableStreamDefaultControllerImpl,
);
}
return;
@@ -1248,7 +1248,7 @@ export function readableStreamTee<T>(
branch1[
sym.readableStreamController
] as ReadableStreamDefaultControllerImpl,
- value1
+ value1,
);
}
if (!canceled2) {
@@ -1256,10 +1256,10 @@ export function readableStreamTee<T>(
branch2[
sym.readableStreamController
] as ReadableStreamDefaultControllerImpl,
- value2
+ value2,
);
}
- }
+ },
);
setPromiseIsHandledToTrue(readPromise);
return Promise.resolve();
@@ -1288,12 +1288,12 @@ export function readableStreamTee<T>(
branch1 = createReadableStream(
startAlgorithm,
pullAlgorithm,
- cancel1Algorithm
+ cancel1Algorithm,
);
branch2 = createReadableStream(
startAlgorithm,
pullAlgorithm,
- cancel2Algorithm
+ cancel2Algorithm,
);
setPromiseIsHandledToTrue(
reader[sym.closedPromise].promise.catch((r) => {
@@ -1301,15 +1301,15 @@ export function readableStreamTee<T>(
branch1[
sym.readableStreamController
] as ReadableStreamDefaultControllerImpl,
- r
+ r,
);
readableStreamDefaultControllerError(
branch2[
sym.readableStreamController
] as ReadableStreamDefaultControllerImpl,
- r
+ r,
);
- })
+ }),
);
return [branch1, branch2];
}
@@ -1340,7 +1340,7 @@ function setUpReadableByteStreamController(
pullAlgorithm: PullAlgorithm,
cancelAlgorithm: CancelAlgorithm,
highWaterMark: number,
- autoAllocateChunkSize: number | undefined
+ autoAllocateChunkSize: number | undefined,
): void {
assert(stream[sym.readableStreamController] === undefined);
if (autoAllocateChunkSize !== undefined) {
@@ -1354,7 +1354,7 @@ function setUpReadableByteStreamController(
controller[sym.queueTotalSize] = 0;
controller[sym.closeRequested] = controller[sym.started] = false;
controller[sym.strategyHWM] = validateAndNormalizeHighWaterMark(
- highWaterMark
+ highWaterMark,
);
controller[sym.pullAlgorithm] = pullAlgorithm;
controller[sym.cancelAlgorithm] = cancelAlgorithm;
@@ -1373,19 +1373,19 @@ function setUpReadableByteStreamController(
},
(r) => {
readableByteStreamControllerError(controller, r);
- }
- )
+ },
+ ),
);
}
export function setUpReadableByteStreamControllerFromUnderlyingSource(
stream: ReadableStreamImpl,
underlyingByteSource: UnderlyingByteSource,
- highWaterMark: number
+ highWaterMark: number,
): void {
assert(underlyingByteSource);
const controller: ReadableByteStreamControllerImpl = Object.create(
- ReadableByteStreamControllerImpl.prototype
+ ReadableByteStreamControllerImpl.prototype,
);
const startAlgorithm: StartAlgorithm = () => {
return invokeOrNoop(underlyingByteSource, "start", controller);
@@ -1394,13 +1394,13 @@ export function setUpReadableByteStreamControllerFromUnderlyingSource(
underlyingByteSource,
"pull",
0,
- controller
+ controller,
);
setFunctionName(pullAlgorithm, "[[pullAlgorithm]]");
const cancelAlgorithm = createAlgorithmFromUnderlyingMethod(
underlyingByteSource,
"cancel",
- 1
+ 1,
);
setFunctionName(cancelAlgorithm, "[[cancelAlgorithm]]");
// 3.13.27.6 Let autoAllocateChunkSize be ? GetV(underlyingByteSource, "autoAllocateChunkSize").
@@ -1412,7 +1412,7 @@ export function setUpReadableByteStreamControllerFromUnderlyingSource(
pullAlgorithm,
cancelAlgorithm,
highWaterMark,
- autoAllocateChunkSize
+ autoAllocateChunkSize,
);
}
@@ -1423,7 +1423,7 @@ function setUpReadableStreamDefaultController<T>(
pullAlgorithm: PullAlgorithm,
cancelAlgorithm: CancelAlgorithm,
highWaterMark: number,
- sizeAlgorithm: SizeAlgorithm<T>
+ sizeAlgorithm: SizeAlgorithm<T>,
): void {
assert(stream[sym.readableStreamController] === undefined);
controller[sym.controlledReadableStream] = stream;
@@ -1449,8 +1449,8 @@ function setUpReadableStreamDefaultController<T>(
},
(r) => {
readableStreamDefaultControllerError(controller, r);
- }
- )
+ },
+ ),
);
}
@@ -1458,11 +1458,11 @@ export function setUpReadableStreamDefaultControllerFromUnderlyingSource<T>(
stream: ReadableStreamImpl<T>,
underlyingSource: UnderlyingSource<T>,
highWaterMark: number,
- sizeAlgorithm: SizeAlgorithm<T>
+ sizeAlgorithm: SizeAlgorithm<T>,
): void {
assert(underlyingSource);
const controller: ReadableStreamDefaultControllerImpl<T> = Object.create(
- ReadableStreamDefaultControllerImpl.prototype
+ ReadableStreamDefaultControllerImpl.prototype,
);
const startAlgorithm: StartAlgorithm = (): void | PromiseLike<void> =>
invokeOrNoop(underlyingSource, "start", controller);
@@ -1470,13 +1470,13 @@ export function setUpReadableStreamDefaultControllerFromUnderlyingSource<T>(
underlyingSource,
"pull",
0,
- controller
+ controller,
);
setFunctionName(pullAlgorithm, "[[pullAlgorithm]]");
const cancelAlgorithm: CancelAlgorithm = createAlgorithmFromUnderlyingMethod(
underlyingSource,
"cancel",
- 1
+ 1,
);
setFunctionName(cancelAlgorithm, "[[cancelAlgorithm]]");
setUpReadableStreamDefaultController(
@@ -1486,7 +1486,7 @@ export function setUpReadableStreamDefaultControllerFromUnderlyingSource<T>(
pullAlgorithm,
cancelAlgorithm,
highWaterMark,
- sizeAlgorithm
+ sizeAlgorithm,
);
}
@@ -1494,7 +1494,7 @@ function setUpTransformStreamDefaultController<I, O>(
stream: TransformStreamImpl<I, O>,
controller: TransformStreamDefaultControllerImpl<I, O>,
transformAlgorithm: TransformAlgorithm<I>,
- flushAlgorithm: FlushAlgorithm
+ flushAlgorithm: FlushAlgorithm,
): void {
assert(isTransformStream(stream));
assert(stream[sym.transformStreamController] === undefined);
@@ -1506,18 +1506,18 @@ function setUpTransformStreamDefaultController<I, O>(
export function setUpTransformStreamDefaultControllerFromTransformer<I, O>(
stream: TransformStreamImpl<I, O>,
- transformer: Transformer<I, O>
+ transformer: Transformer<I, O>,
): void {
assert(transformer);
const controller = Object.create(
- TransformStreamDefaultControllerImpl.prototype
+ TransformStreamDefaultControllerImpl.prototype,
) as TransformStreamDefaultControllerImpl<I, O>;
let transformAlgorithm: TransformAlgorithm<I> = (chunk) => {
try {
transformStreamDefaultControllerEnqueue(
controller,
// it defaults to no tranformation, so I is assumed to be O
- (chunk as unknown) as O
+ (chunk as unknown) as O,
);
} catch (e) {
return Promise.reject(e);
@@ -1536,13 +1536,13 @@ export function setUpTransformStreamDefaultControllerFromTransformer<I, O>(
transformer,
"flush",
0,
- controller
+ controller,
);
setUpTransformStreamDefaultController(
stream,
controller,
transformAlgorithm,
- flushAlgorithm
+ flushAlgorithm,
);
}
@@ -1554,7 +1554,7 @@ function setUpWritableStreamDefaultController<W>(
closeAlgorithm: CloseAlgorithm,
abortAlgorithm: AbortAlgorithm,
highWaterMark: number,
- sizeAlgorithm: SizeAlgorithm<W>
+ sizeAlgorithm: SizeAlgorithm<W>,
): void {
assert(isWritableStream(stream));
assert(stream[sym.writableStreamController] === undefined);
@@ -1569,7 +1569,7 @@ function setUpWritableStreamDefaultController<W>(
controller[sym.closeAlgorithm] = closeAlgorithm;
controller[sym.abortAlgorithm] = abortAlgorithm;
const backpressure = writableStreamDefaultControllerGetBackpressure(
- controller
+ controller,
);
writableStreamUpdateBackpressure(stream, backpressure);
const startResult = startAlgorithm();
@@ -1578,19 +1578,19 @@ function setUpWritableStreamDefaultController<W>(
startPromise.then(
() => {
assert(
- stream[sym.state] === "writable" || stream[sym.state] === "erroring"
+ stream[sym.state] === "writable" || stream[sym.state] === "erroring",
);
controller[sym.started] = true;
writableStreamDefaultControllerAdvanceQueueIfNeeded(controller);
},
(r) => {
assert(
- stream[sym.state] === "writable" || stream[sym.state] === "erroring"
+ stream[sym.state] === "writable" || stream[sym.state] === "erroring",
);
controller[sym.started] = true;
writableStreamDealWithRejection(stream, r);
- }
- )
+ },
+ ),
);
}
@@ -1598,11 +1598,11 @@ export function setUpWritableStreamDefaultControllerFromUnderlyingSink<W>(
stream: WritableStreamImpl<W>,
underlyingSink: UnderlyingSink<W>,
highWaterMark: number,
- sizeAlgorithm: SizeAlgorithm<W>
+ sizeAlgorithm: SizeAlgorithm<W>,
): void {
assert(underlyingSink);
const controller = Object.create(
- WritableStreamDefaultControllerImpl.prototype
+ WritableStreamDefaultControllerImpl.prototype,
);
const startAlgorithm = (): void | PromiseLike<void> => {
return invokeOrNoop(underlyingSink, "start", controller);
@@ -1611,19 +1611,19 @@ export function setUpWritableStreamDefaultControllerFromUnderlyingSink<W>(
underlyingSink,
"write",
1,
- controller
+ controller,
);
setFunctionName(writeAlgorithm, "[[writeAlgorithm]]");
const closeAlgorithm = createAlgorithmFromUnderlyingMethod(
underlyingSink,
"close",
- 0
+ 0,
);
setFunctionName(closeAlgorithm, "[[closeAlgorithm]]");
const abortAlgorithm = createAlgorithmFromUnderlyingMethod(
underlyingSink,
"abort",
- 1
+ 1,
);
setFunctionName(abortAlgorithm, "[[abortAlgorithm]]");
setUpWritableStreamDefaultController(
@@ -1634,12 +1634,12 @@ export function setUpWritableStreamDefaultControllerFromUnderlyingSink<W>(
closeAlgorithm,
abortAlgorithm,
highWaterMark,
- sizeAlgorithm
+ sizeAlgorithm,
);
}
function transformStreamDefaultControllerClearAlgorithms<I, O>(
- controller: TransformStreamDefaultControllerImpl<I, O>
+ controller: TransformStreamDefaultControllerImpl<I, O>,
): void {
(controller as any)[sym.transformAlgorithm] = undefined;
(controller as any)[sym.flushAlgorithm] = undefined;
@@ -1647,7 +1647,7 @@ function transformStreamDefaultControllerClearAlgorithms<I, O>(
export function transformStreamDefaultControllerEnqueue<I, O>(
controller: TransformStreamDefaultControllerImpl<I, O>,
- chunk: O
+ chunk: O,
): void {
const stream = controller[sym.controlledTransformStream];
const readableController = stream[sym.readable][
@@ -1655,7 +1655,7 @@ export function transformStreamDefaultControllerEnqueue<I, O>(
] as ReadableStreamDefaultControllerImpl<O>;
if (!readableStreamDefaultControllerCanCloseOrEnqueue(readableController)) {
throw new TypeError(
- "TransformStream's readable controller cannot be closed or enqueued."
+ "TransformStream's readable controller cannot be closed or enqueued.",
);
}
try {
@@ -1665,7 +1665,7 @@ export function transformStreamDefaultControllerEnqueue<I, O>(
throw stream[sym.readable][sym.storedError];
}
const backpressure = readableStreamDefaultControllerHasBackpressure(
- readableController
+ readableController,
);
if (backpressure) {
transformStreamSetBackpressure(stream, true);
@@ -1674,14 +1674,14 @@ export function transformStreamDefaultControllerEnqueue<I, O>(
export function transformStreamDefaultControllerError<I, O>(
controller: TransformStreamDefaultControllerImpl<I, O>,
- e: any
+ e: any,
): void {
transformStreamError(controller[sym.controlledTransformStream], e);
}
function transformStreamDefaultControllerPerformTransform<I, O>(
controller: TransformStreamDefaultControllerImpl<I, O>,
- chunk: I
+ chunk: I,
): Promise<void> {
const transformPromise = controller[sym.transformAlgorithm](chunk);
return transformPromise.then(undefined, (r) => {
@@ -1692,14 +1692,14 @@ function transformStreamDefaultControllerPerformTransform<I, O>(
function transformStreamDefaultSinkAbortAlgorithm<I, O>(
stream: TransformStreamImpl<I, O>,
- reason: any
+ reason: any,
): Promise<void> {
transformStreamError(stream, reason);
return Promise.resolve(undefined);
}
function transformStreamDefaultSinkCloseAlgorithm<I, O>(
- stream: TransformStreamImpl<I, O>
+ stream: TransformStreamImpl<I, O>,
): Promise<void> {
const readable = stream[sym.readable];
const controller = stream[sym.transformStreamController];
@@ -1722,13 +1722,13 @@ function transformStreamDefaultSinkCloseAlgorithm<I, O>(
(r) => {
transformStreamError(stream, r);
throw readable[sym.storedError];
- }
+ },
);
}
function transformStreamDefaultSinkWriteAlgorithm<I, O>(
stream: TransformStreamImpl<I, O>,
- chunk: I
+ chunk: I,
): Promise<void> {
assert(stream[sym.writable][sym.state] === "writable");
const controller = stream[sym.transformStreamController];
@@ -1744,7 +1744,7 @@ function transformStreamDefaultSinkWriteAlgorithm<I, O>(
assert(state === "writable");
return transformStreamDefaultControllerPerformTransform(
controller,
- chunk
+ chunk,
);
});
}
@@ -1752,7 +1752,7 @@ function transformStreamDefaultSinkWriteAlgorithm<I, O>(
}
function transformStreamDefaultSourcePullAlgorithm<I, O>(
- stream: TransformStreamImpl<I, O>
+ stream: TransformStreamImpl<I, O>,
): Promise<void> {
assert(stream[sym.backpressure] === true);
assert(stream[sym.backpressureChangePromise] !== undefined);
@@ -1762,19 +1762,19 @@ function transformStreamDefaultSourcePullAlgorithm<I, O>(
function transformStreamError<I, O>(
stream: TransformStreamImpl<I, O>,
- e: any
+ e: any,
): void {
readableStreamDefaultControllerError(
stream[sym.readable][
sym.readableStreamController
] as ReadableStreamDefaultControllerImpl<O>,
- e
+ e,
);
transformStreamErrorWritableAndUnblockWrite(stream, e);
}
export function transformStreamDefaultControllerTerminate<I, O>(
- controller: TransformStreamDefaultControllerImpl<I, O>
+ controller: TransformStreamDefaultControllerImpl<I, O>,
): void {
const stream = controller[sym.controlledTransformStream];
const readableController = stream[sym.readable][
@@ -1787,14 +1787,14 @@ export function transformStreamDefaultControllerTerminate<I, O>(
function transformStreamErrorWritableAndUnblockWrite<I, O>(
stream: TransformStreamImpl<I, O>,
- e: any
+ e: any,
): void {
transformStreamDefaultControllerClearAlgorithms(
- stream[sym.transformStreamController]
+ stream[sym.transformStreamController],
);
writableStreamDefaultControllerErrorIfNeeded(
stream[sym.writable][sym.writableStreamController]!,
- e
+ e,
);
if (stream[sym.backpressure]) {
transformStreamSetBackpressure(stream, false);
@@ -1803,7 +1803,7 @@ function transformStreamErrorWritableAndUnblockWrite<I, O>(
function transformStreamSetBackpressure<I, O>(
stream: TransformStreamImpl<I, O>,
- backpressure: boolean
+ backpressure: boolean,
): void {
assert(stream[sym.backpressure] !== backpressure);
if (stream[sym.backpressureChangePromise] !== undefined) {
@@ -1828,12 +1828,12 @@ function transferArrayBuffer(buffer: ArrayBuffer): ArrayBuffer {
}
export function validateAndNormalizeHighWaterMark(
- highWaterMark: number
+ highWaterMark: number,
): number {
highWaterMark = Number(highWaterMark);
if (Number.isNaN(highWaterMark) || highWaterMark < 0) {
throw new RangeError(
- `highWaterMark must be a positive number or Infinity. Received: ${highWaterMark}.`
+ `highWaterMark must be a positive number or Infinity. Received: ${highWaterMark}.`,
);
}
return highWaterMark;
@@ -1841,7 +1841,7 @@ export function validateAndNormalizeHighWaterMark(
export function writableStreamAbort<W>(
stream: WritableStreamImpl<W>,
- reason: any
+ reason: any,
): Promise<void> {
const state = stream[sym.state];
if (state === "closed" || state === "errored") {
@@ -1866,7 +1866,7 @@ export function writableStreamAbort<W>(
}
function writableStreamAddWriteRequest<W>(
- stream: WritableStreamImpl<W>
+ stream: WritableStreamImpl<W>,
): Promise<void> {
assert(isWritableStream(stream));
assert(stream[sym.state] === "writable");
@@ -1876,12 +1876,14 @@ function writableStreamAddWriteRequest<W>(
}
export function writableStreamClose<W>(
- stream: WritableStreamImpl<W>
+ stream: WritableStreamImpl<W>,
): Promise<void> {
const state = stream[sym.state];
if (state === "closed" || state === "errored") {
return Promise.reject(
- new TypeError("Cannot close an already closed or errored WritableStream.")
+ new TypeError(
+ "Cannot close an already closed or errored WritableStream.",
+ ),
);
}
assert(!writableStreamCloseQueuedOrInFlight(stream));
@@ -1898,7 +1900,7 @@ export function writableStreamClose<W>(
}
export function writableStreamCloseQueuedOrInFlight<W>(
- stream: WritableStreamImpl<W>
+ stream: WritableStreamImpl<W>,
): boolean {
return !(
stream[sym.closeRequest] === undefined &&
@@ -1908,7 +1910,7 @@ export function writableStreamCloseQueuedOrInFlight<W>(
function writableStreamDealWithRejection<W>(
stream: WritableStreamImpl<W>,
- error: any
+ error: any,
): void {
const state = stream[sym.state];
if (state === "writable") {
@@ -1920,7 +1922,7 @@ function writableStreamDealWithRejection<W>(
}
function writableStreamDefaultControllerAdvanceQueueIfNeeded<W>(
- controller: WritableStreamDefaultControllerImpl<W>
+ controller: WritableStreamDefaultControllerImpl<W>,
): void {
const stream = controller[sym.controlledWritableStream];
if (!controller[sym.started]) {
@@ -1947,7 +1949,7 @@ function writableStreamDefaultControllerAdvanceQueueIfNeeded<W>(
}
export function writableStreamDefaultControllerClearAlgorithms<W>(
- controller: WritableStreamDefaultControllerImpl<W>
+ controller: WritableStreamDefaultControllerImpl<W>,
): void {
(controller as any)[sym.writeAlgorithm] = undefined;
(controller as any)[sym.closeAlgorithm] = undefined;
@@ -1956,7 +1958,7 @@ export function writableStreamDefaultControllerClearAlgorithms<W>(
}
function writableStreamDefaultControllerClose<W>(
- controller: WritableStreamDefaultControllerImpl<W>
+ controller: WritableStreamDefaultControllerImpl<W>,
): void {
enqueueValueWithSize(controller, "close", 0);
writableStreamDefaultControllerAdvanceQueueIfNeeded(controller);
@@ -1964,7 +1966,7 @@ function writableStreamDefaultControllerClose<W>(
export function writableStreamDefaultControllerError<W>(
controller: WritableStreamDefaultControllerImpl<W>,
- error: any
+ error: any,
): void {
const stream = controller[sym.controlledWritableStream];
assert(stream[sym.state] === "writable");
@@ -1974,7 +1976,7 @@ export function writableStreamDefaultControllerError<W>(
function writableStreamDefaultControllerErrorIfNeeded<W>(
controller: WritableStreamDefaultControllerImpl<W>,
- error: any
+ error: any,
): void {
if (controller[sym.controlledWritableStream][sym.state] === "writable") {
writableStreamDefaultControllerError(controller, error);
@@ -1982,7 +1984,7 @@ function writableStreamDefaultControllerErrorIfNeeded<W>(
}
function writableStreamDefaultControllerGetBackpressure<W>(
- controller: WritableStreamDefaultControllerImpl<W>
+ controller: WritableStreamDefaultControllerImpl<W>,
): boolean {
const desiredSize = writableStreamDefaultControllerGetDesiredSize(controller);
return desiredSize <= 0;
@@ -1990,7 +1992,7 @@ function writableStreamDefaultControllerGetBackpressure<W>(
function writableStreamDefaultControllerGetChunkSize<W>(
controller: WritableStreamDefaultControllerImpl<W>,
- chunk: W
+ chunk: W,
): number {
let returnValue: number;
try {
@@ -2003,13 +2005,13 @@ function writableStreamDefaultControllerGetChunkSize<W>(
}
function writableStreamDefaultControllerGetDesiredSize<W>(
- controller: WritableStreamDefaultControllerImpl<W>
+ controller: WritableStreamDefaultControllerImpl<W>,
): number {
return controller[sym.strategyHWM] - controller[sym.queueTotalSize];
}
function writableStreamDefaultControllerProcessClose<W>(
- controller: WritableStreamDefaultControllerImpl<W>
+ controller: WritableStreamDefaultControllerImpl<W>,
): void {
const stream = controller[sym.controlledWritableStream];
writableStreamMarkCloseRequestInFlight(stream);
@@ -2024,14 +2026,14 @@ function writableStreamDefaultControllerProcessClose<W>(
},
(reason) => {
writableStreamFinishInFlightCloseWithError(stream, reason);
- }
- )
+ },
+ ),
);
}
function writableStreamDefaultControllerProcessWrite<W>(
controller: WritableStreamDefaultControllerImpl<W>,
- chunk: W
+ chunk: W,
): void {
const stream = controller[sym.controlledWritableStream];
writableStreamMarkFirstWriteRequestInFlight(stream);
@@ -2048,7 +2050,7 @@ function writableStreamDefaultControllerProcessWrite<W>(
state === "writable"
) {
const backpressure = writableStreamDefaultControllerGetBackpressure(
- controller
+ controller,
);
writableStreamUpdateBackpressure(stream, backpressure);
}
@@ -2059,15 +2061,15 @@ function writableStreamDefaultControllerProcessWrite<W>(
writableStreamDefaultControllerClearAlgorithms(controller);
}
writableStreamFinishInFlightWriteWithError(stream, reason);
- }
- )
+ },
+ ),
);
}
function writableStreamDefaultControllerWrite<W>(
controller: WritableStreamDefaultControllerImpl<W>,
chunk: W,
- chunkSize: number
+ chunkSize: number,
): void {
const writeRecord = { chunk };
try {
@@ -2082,7 +2084,7 @@ function writableStreamDefaultControllerWrite<W>(
stream[sym.state] === "writable"
) {
const backpressure = writableStreamDefaultControllerGetBackpressure(
- controller
+ controller,
);
writableStreamUpdateBackpressure(stream, backpressure);
}
@@ -2091,7 +2093,7 @@ function writableStreamDefaultControllerWrite<W>(
export function writableStreamDefaultWriterAbort<W>(
writer: WritableStreamDefaultWriterImpl<W>,
- reason: any
+ reason: any,
): Promise<void> {
const stream = writer[sym.ownerWritableStream];
assert(stream);
@@ -2099,7 +2101,7 @@ export function writableStreamDefaultWriterAbort<W>(
}
export function writableStreamDefaultWriterClose<W>(
- writer: WritableStreamDefaultWriterImpl<W>
+ writer: WritableStreamDefaultWriterImpl<W>,
): Promise<void> {
const stream = writer[sym.ownerWritableStream];
assert(stream);
@@ -2107,7 +2109,7 @@ export function writableStreamDefaultWriterClose<W>(
}
function writableStreamDefaultWriterCloseWithErrorPropagation<W>(
- writer: WritableStreamDefaultWriterImpl<W>
+ writer: WritableStreamDefaultWriterImpl<W>,
): Promise<void> {
const stream = writer[sym.ownerWritableStream];
assert(stream);
@@ -2124,7 +2126,7 @@ function writableStreamDefaultWriterCloseWithErrorPropagation<W>(
function writableStreamDefaultWriterEnsureClosePromiseRejected<W>(
writer: WritableStreamDefaultWriterImpl<W>,
- error: any
+ error: any,
): void {
if (writer[sym.closedPromise].reject) {
writer[sym.closedPromise].reject!(error);
@@ -2138,7 +2140,7 @@ function writableStreamDefaultWriterEnsureClosePromiseRejected<W>(
function writableStreamDefaultWriterEnsureReadyPromiseRejected<W>(
writer: WritableStreamDefaultWriterImpl<W>,
- error: any
+ error: any,
): void {
if (writer[sym.readyPromise].reject) {
writer[sym.readyPromise].reject!(error);
@@ -2154,7 +2156,7 @@ function writableStreamDefaultWriterEnsureReadyPromiseRejected<W>(
export function writableStreamDefaultWriterWrite<W>(
writer: WritableStreamDefaultWriterImpl<W>,
- chunk: W
+ chunk: W,
): Promise<void> {
const stream = writer[sym.ownerWritableStream];
assert(stream);
@@ -2162,7 +2164,7 @@ export function writableStreamDefaultWriterWrite<W>(
assert(controller);
const chunkSize = writableStreamDefaultControllerGetChunkSize(
controller,
- chunk
+ chunk,
);
if (stream !== writer[sym.ownerWritableStream]) {
return Promise.reject("Writer has incorrect WritableStream.");
@@ -2184,7 +2186,7 @@ export function writableStreamDefaultWriterWrite<W>(
}
export function writableStreamDefaultWriterGetDesiredSize<W>(
- writer: WritableStreamDefaultWriterImpl<W>
+ writer: WritableStreamDefaultWriterImpl<W>,
): number | null {
const stream = writer[sym.ownerWritableStream];
const state = stream[sym.state];
@@ -2195,18 +2197,18 @@ export function writableStreamDefaultWriterGetDesiredSize<W>(
return 0;
}
return writableStreamDefaultControllerGetDesiredSize(
- stream[sym.writableStreamController]!
+ stream[sym.writableStreamController]!,
);
}
export function writableStreamDefaultWriterRelease<W>(
- writer: WritableStreamDefaultWriterImpl<W>
+ writer: WritableStreamDefaultWriterImpl<W>,
): void {
const stream = writer[sym.ownerWritableStream];
assert(stream);
assert(stream[sym.writer] === writer);
const releasedError = new TypeError(
- "Writer was released and can no longer be used to monitor the stream's closedness."
+ "Writer was released and can no longer be used to monitor the stream's closedness.",
);
writableStreamDefaultWriterEnsureReadyPromiseRejected(writer, releasedError);
writableStreamDefaultWriterEnsureClosePromiseRejected(writer, releasedError);
@@ -2239,7 +2241,7 @@ function writableStreamFinishErroring<W>(stream: WritableStreamImpl<W>): void {
return;
}
const promise = stream[sym.writableStreamController]![sym.abortSteps](
- abortRequest.reason
+ abortRequest.reason,
);
setPromiseIsHandledToTrue(
promise.then(
@@ -2252,13 +2254,13 @@ function writableStreamFinishErroring<W>(stream: WritableStreamImpl<W>): void {
assert(abortRequest.promise.reject);
abortRequest.promise.reject(reason);
writableStreamRejectCloseAndClosedPromiseIfNeeded(stream);
- }
- )
+ },
+ ),
);
}
function writableStreamFinishInFlightClose<W>(
- stream: WritableStreamImpl<W>
+ stream: WritableStreamImpl<W>,
): void {
assert(stream[sym.inFlightCloseRequest]);
stream[sym.inFlightCloseRequest]?.resolve!();
@@ -2283,7 +2285,7 @@ function writableStreamFinishInFlightClose<W>(
function writableStreamFinishInFlightCloseWithError<W>(
stream: WritableStreamImpl<W>,
- error: any
+ error: any,
): void {
assert(stream[sym.inFlightCloseRequest]);
stream[sym.inFlightCloseRequest]?.reject!(error);
@@ -2297,7 +2299,7 @@ function writableStreamFinishInFlightCloseWithError<W>(
}
function writableStreamFinishInFlightWrite<W>(
- stream: WritableStreamImpl<W>
+ stream: WritableStreamImpl<W>,
): void {
assert(stream[sym.inFlightWriteRequest]);
stream[sym.inFlightWriteRequest]!.resolve();
@@ -2306,7 +2308,7 @@ function writableStreamFinishInFlightWrite<W>(
function writableStreamFinishInFlightWriteWithError<W>(
stream: WritableStreamImpl<W>,
- error: any
+ error: any,
): void {
assert(stream[sym.inFlightWriteRequest]);
stream[sym.inFlightWriteRequest]!.reject!(error);
@@ -2316,7 +2318,7 @@ function writableStreamFinishInFlightWriteWithError<W>(
}
function writableStreamHasOperationMarkedInFlight<W>(
- stream: WritableStreamImpl<W>
+ stream: WritableStreamImpl<W>,
): boolean {
return !(
stream[sym.inFlightWriteRequest] === undefined &&
@@ -2325,7 +2327,7 @@ function writableStreamHasOperationMarkedInFlight<W>(
}
function writableStreamMarkCloseRequestInFlight<W>(
- stream: WritableStreamImpl<W>
+ stream: WritableStreamImpl<W>,
): void {
assert(stream[sym.inFlightCloseRequest] === undefined);
assert(stream[sym.closeRequest] !== undefined);
@@ -2334,7 +2336,7 @@ function writableStreamMarkCloseRequestInFlight<W>(
}
function writableStreamMarkFirstWriteRequestInFlight<W>(
- stream: WritableStreamImpl<W>
+ stream: WritableStreamImpl<W>,
): void {
assert(stream[sym.inFlightWriteRequest] === undefined);
assert(stream[sym.writeRequests].length);
@@ -2343,7 +2345,7 @@ function writableStreamMarkFirstWriteRequestInFlight<W>(
}
function writableStreamRejectCloseAndClosedPromiseIfNeeded<W>(
- stream: WritableStreamImpl<W>
+ stream: WritableStreamImpl<W>,
): void {
assert(stream[sym.state] === "errored");
if (stream[sym.closeRequest]) {
@@ -2360,7 +2362,7 @@ function writableStreamRejectCloseAndClosedPromiseIfNeeded<W>(
function writableStreamStartErroring<W>(
stream: WritableStreamImpl<W>,
- reason: any
+ reason: any,
): void {
assert(stream[sym.storedError] === undefined);
assert(stream[sym.state] === "writable");
@@ -2382,7 +2384,7 @@ function writableStreamStartErroring<W>(
function writableStreamUpdateBackpressure<W>(
stream: WritableStreamImpl<W>,
- backpressure: boolean
+ backpressure: boolean,
): void {
assert(stream[sym.state] === "writable");
assert(!writableStreamCloseQueuedOrInFlight(stream));
diff --git a/cli/js/web/streams/queuing_strategy.ts b/cli/js/web/streams/queuing_strategy.ts
index 8aa30e142..818f0d51b 100644
--- a/cli/js/web/streams/queuing_strategy.ts
+++ b/cli/js/web/streams/queuing_strategy.ts
@@ -15,9 +15,9 @@ export class CountQueuingStrategyImpl implements CountQueuingStrategy {
}
[customInspect](): string {
- return `${this.constructor.name} { highWaterMark: ${String(
- this.highWaterMark
- )}, size: f }`;
+ return `${this.constructor.name} { highWaterMark: ${
+ String(this.highWaterMark)
+ }, size: f }`;
}
}
@@ -40,9 +40,9 @@ export class ByteLengthQueuingStrategyImpl
}
[customInspect](): string {
- return `${this.constructor.name} { highWaterMark: ${String(
- this.highWaterMark
- )}, size: f }`;
+ return `${this.constructor.name} { highWaterMark: ${
+ String(this.highWaterMark)
+ }, size: f }`;
}
}
diff --git a/cli/js/web/streams/readable_byte_stream_controller.ts b/cli/js/web/streams/readable_byte_stream_controller.ts
index 4a7ffae12..eb4374604 100644
--- a/cli/js/web/streams/readable_byte_stream_controller.ts
+++ b/cli/js/web/streams/readable_byte_stream_controller.ts
@@ -42,7 +42,7 @@ export class ReadableByteStreamControllerImpl
private constructor() {
throw new TypeError(
- "ReadableByteStreamController's constructor cannot be called."
+ "ReadableByteStreamController's constructor cannot be called.",
);
}
@@ -66,7 +66,7 @@ export class ReadableByteStreamControllerImpl
}
if (this[sym.controlledReadableByteStream][sym.state] !== "readable") {
throw new TypeError(
- "ReadableByteStreamController's stream is not in a readable state."
+ "ReadableByteStreamController's stream is not in a readable state.",
);
}
readableByteStreamControllerClose(this);
@@ -81,12 +81,12 @@ export class ReadableByteStreamControllerImpl
}
if (this[sym.controlledReadableByteStream][sym.state] !== "readable") {
throw new TypeError(
- "ReadableByteStreamController's stream is not in a readable state."
+ "ReadableByteStreamController's stream is not in a readable state.",
);
}
if (!ArrayBuffer.isView(chunk)) {
throw new TypeError(
- "You can only enqueue array buffer views when using a ReadableByteStreamController"
+ "You can only enqueue array buffer views when using a ReadableByteStreamController",
);
}
if (isDetachedBuffer(chunk.buffer)) {
@@ -126,8 +126,8 @@ export class ReadableByteStreamControllerImpl
readableStreamCreateReadResult(
view,
false,
- stream[sym.reader]![sym.forAuthorCode]
- )
+ stream[sym.reader]![sym.forAuthorCode],
+ ),
);
}
// 3.11.5.2.5 If autoAllocateChunkSize is not undefined,
@@ -137,13 +137,13 @@ export class ReadableByteStreamControllerImpl
}
[customInspect](): string {
- return `${this.constructor.name} { byobRequest: ${String(
- this.byobRequest
- )}, desiredSize: ${String(this.desiredSize)} }`;
+ return `${this.constructor.name} { byobRequest: ${
+ String(this.byobRequest)
+ }, desiredSize: ${String(this.desiredSize)} }`;
}
}
setFunctionName(
ReadableByteStreamControllerImpl,
- "ReadableByteStreamController"
+ "ReadableByteStreamController",
);
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);
}
diff --git a/cli/js/web/streams/readable_stream_async_iterator.ts b/cli/js/web/streams/readable_stream_async_iterator.ts
index cd656e73d..c6b9759a5 100644
--- a/cli/js/web/streams/readable_stream_async_iterator.ts
+++ b/cli/js/web/streams/readable_stream_async_iterator.ts
@@ -12,25 +12,24 @@ import {
import { assert } from "../../util.ts";
// eslint-disable-next-line @typescript-eslint/no-explicit-any
-const AsyncIteratorPrototype: AsyncIterableIterator<any> = Object.getPrototypeOf(
- Object.getPrototypeOf(async function* () {}).prototype
-);
+const AsyncIteratorPrototype: AsyncIterableIterator<any> = Object
+ .getPrototypeOf(Object.getPrototypeOf(async function* () {}).prototype);
-export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator = Object.setPrototypeOf(
- {
+export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator =
+ Object.setPrototypeOf({
next(
- this: ReadableStreamAsyncIterator
+ this: ReadableStreamAsyncIterator,
// eslint-disable-next-line @typescript-eslint/no-explicit-any
): Promise<ReadableStreamReadResult<any>> {
if (!isReadableStreamAsyncIterator(this)) {
return Promise.reject(
- new TypeError("invalid ReadableStreamAsyncIterator.")
+ new TypeError("invalid ReadableStreamAsyncIterator."),
);
}
const reader = this[sym.asyncIteratorReader];
if (!reader[sym.ownerReadableStream]) {
return Promise.reject(
- new TypeError("reader owner ReadableStream is undefined.")
+ new TypeError("reader owner ReadableStream is undefined."),
);
}
return readableStreamDefaultReaderRead(reader).then((result) => {
@@ -47,23 +46,23 @@ export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator =
return(
this: ReadableStreamAsyncIterator,
// eslint-disable-next-line @typescript-eslint/no-explicit-any
- value?: any | PromiseLike<any>
+ value?: any | PromiseLike<any>,
// eslint-disable-next-line @typescript-eslint/no-explicit-any
): Promise<ReadableStreamReadResult<any>> {
if (!isReadableStreamAsyncIterator(this)) {
return Promise.reject(
- new TypeError("invalid ReadableStreamAsyncIterator.")
+ new TypeError("invalid ReadableStreamAsyncIterator."),
);
}
const reader = this[sym.asyncIteratorReader];
if (!reader[sym.ownerReadableStream]) {
return Promise.reject(
- new TypeError("reader owner ReadableStream is undefined.")
+ new TypeError("reader owner ReadableStream is undefined."),
);
}
if (reader[sym.readRequests].length) {
return Promise.reject(
- new TypeError("reader has outstanding read requests.")
+ new TypeError("reader has outstanding read requests."),
);
}
if (!this[sym.preventCancel]) {
@@ -74,8 +73,8 @@ export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator =
);
}
readableStreamReaderGenericRelease(reader);
- return Promise.resolve(readableStreamCreateReadResult(value, true, true));
+ return Promise.resolve(
+ readableStreamCreateReadResult(value, true, true),
+ );
},
- },
- AsyncIteratorPrototype
-);
+ }, AsyncIteratorPrototype);
diff --git a/cli/js/web/streams/readable_stream_default_controller.ts b/cli/js/web/streams/readable_stream_default_controller.ts
index 066bc8a8f..8536712b9 100644
--- a/cli/js/web/streams/readable_stream_default_controller.ts
+++ b/cli/js/web/streams/readable_stream_default_controller.ts
@@ -41,7 +41,7 @@ export class ReadableStreamDefaultControllerImpl<R = any>
private constructor() {
throw new TypeError(
- "ReadableStreamDefaultController's constructor cannot be called."
+ "ReadableStreamDefaultController's constructor cannot be called.",
);
}
@@ -58,7 +58,7 @@ export class ReadableStreamDefaultControllerImpl<R = any>
}
if (!readableStreamDefaultControllerCanCloseOrEnqueue(this)) {
throw new TypeError(
- "ReadableStreamDefaultController cannot close or enqueue."
+ "ReadableStreamDefaultController cannot close or enqueue.",
);
}
readableStreamDefaultControllerClose(this);
@@ -104,8 +104,8 @@ export class ReadableStreamDefaultControllerImpl<R = any>
readableStreamCreateReadResult(
chunk,
false,
- stream[sym.reader]![sym.forAuthorCode]
- )
+ stream[sym.reader]![sym.forAuthorCode],
+ ),
);
}
const pendingPromise = readableStreamAddReadRequest(stream);
@@ -114,13 +114,13 @@ export class ReadableStreamDefaultControllerImpl<R = any>
}
[customInspect](): string {
- return `${this.constructor.name} { desiredSize: ${String(
- this.desiredSize
- )} }`;
+ return `${this.constructor.name} { desiredSize: ${
+ String(this.desiredSize)
+ } }`;
}
}
setFunctionName(
ReadableStreamDefaultControllerImpl,
- "ReadableStreamDefaultController"
+ "ReadableStreamDefaultController",
);
diff --git a/cli/js/web/streams/readable_stream_default_reader.ts b/cli/js/web/streams/readable_stream_default_reader.ts
index 4ed0a5c7c..88260effb 100644
--- a/cli/js/web/streams/readable_stream_default_reader.ts
+++ b/cli/js/web/streams/readable_stream_default_reader.ts
@@ -37,12 +37,12 @@ export class ReadableStreamDefaultReaderImpl<R = any>
get closed(): Promise<void> {
if (!isReadableStreamDefaultReader(this)) {
return Promise.reject(
- new TypeError("Invalid ReadableStreamDefaultReader.")
+ new TypeError("Invalid ReadableStreamDefaultReader."),
);
}
return (
this[sym.closedPromise].promise ??
- Promise.reject(new TypeError("Invalid reader."))
+ Promise.reject(new TypeError("Invalid reader."))
);
}
@@ -50,7 +50,7 @@ export class ReadableStreamDefaultReaderImpl<R = any>
cancel(reason?: any): Promise<void> {
if (!isReadableStreamDefaultReader(this)) {
return Promise.reject(
- new TypeError("Invalid ReadableStreamDefaultReader.")
+ new TypeError("Invalid ReadableStreamDefaultReader."),
);
}
if (!this[sym.ownerReadableStream]) {
@@ -62,7 +62,7 @@ export class ReadableStreamDefaultReaderImpl<R = any>
read(): Promise<ReadableStreamReadResult<R>> {
if (!isReadableStreamDefaultReader(this)) {
return Promise.reject(
- new TypeError("Invalid ReadableStreamDefaultReader.")
+ new TypeError("Invalid ReadableStreamDefaultReader."),
);
}
if (!this[sym.ownerReadableStream]) {
diff --git a/cli/js/web/streams/symbols.ts b/cli/js/web/streams/symbols.ts
index 9c0a336e5..82d668598 100644
--- a/cli/js/web/streams/symbols.ts
+++ b/cli/js/web/streams/symbols.ts
@@ -20,7 +20,7 @@ export const closedPromise = Symbol("closedPromise");
export const closeRequest = Symbol("closeRequest");
export const closeRequested = Symbol("closeRequested");
export const controlledReadableByteStream = Symbol(
- "controlledReadableByteStream"
+ "controlledReadableByteStream",
);
export const controlledReadableStream = Symbol("controlledReadableStream");
export const controlledTransformStream = Symbol("controlledTransformStream");
diff --git a/cli/js/web/streams/transform_stream.ts b/cli/js/web/streams/transform_stream.ts
index 1c63a553b..f6924aead 100644
--- a/cli/js/web/streams/transform_stream.ts
+++ b/cli/js/web/streams/transform_stream.ts
@@ -29,7 +29,7 @@ export class TransformStreamImpl<I = any, O = any>
constructor(
transformer: Transformer<I, O> = {},
writableStrategy: QueuingStrategy<I> = {},
- readableStrategy: QueuingStrategy<O> = {}
+ readableStrategy: QueuingStrategy<O> = {},
) {
const writableSizeFunction = writableStrategy.size;
let writableHighWaterMark = writableStrategy.highWaterMark;
@@ -38,36 +38,36 @@ export class TransformStreamImpl<I = any, O = any>
const writableType = transformer.writableType;
if (writableType !== undefined) {
throw new RangeError(
- `Expected transformer writableType to be undefined, received "${String(
- writableType
- )}"`
+ `Expected transformer writableType to be undefined, received "${
+ String(writableType)
+ }"`,
);
}
const writableSizeAlgorithm = makeSizeAlgorithmFromSizeFunction(
- writableSizeFunction
+ writableSizeFunction,
);
if (writableHighWaterMark === undefined) {
writableHighWaterMark = 1;
}
writableHighWaterMark = validateAndNormalizeHighWaterMark(
- writableHighWaterMark
+ writableHighWaterMark,
);
const readableType = transformer.readableType;
if (readableType !== undefined) {
throw new RangeError(
- `Expected transformer readableType to be undefined, received "${String(
- readableType
- )}"`
+ `Expected transformer readableType to be undefined, received "${
+ String(readableType)
+ }"`,
);
}
const readableSizeAlgorithm = makeSizeAlgorithmFromSizeFunction(
- readableSizeFunction
+ readableSizeFunction,
);
if (readableHighWaterMark === undefined) {
readableHighWaterMark = 1;
}
readableHighWaterMark = validateAndNormalizeHighWaterMark(
- readableHighWaterMark
+ readableHighWaterMark,
);
const startPromise = getDeferred<void>();
initializeTransformStream(
@@ -76,7 +76,7 @@ export class TransformStreamImpl<I = any, O = any>
writableHighWaterMark,
writableSizeAlgorithm,
readableHighWaterMark,
- readableSizeAlgorithm
+ readableSizeAlgorithm,
);
// the brand check expects this, and the brand check occurs in the following
// but the property hasn't been defined.
@@ -89,7 +89,7 @@ export class TransformStreamImpl<I = any, O = any>
const startResult: void | PromiseLike<void> = invokeOrNoop(
transformer,
"start",
- this[sym.transformStreamController]
+ this[sym.transformStreamController],
);
startPromise.resolve(startResult);
}
@@ -109,9 +109,9 @@ export class TransformStreamImpl<I = any, O = any>
}
[customInspect](): string {
- return `${this.constructor.name} {\n readable: ${inspect(
- this.readable
- )}\n writable: ${inspect(this.writable)}\n}`;
+ return `${this.constructor.name} {\n readable: ${
+ inspect(this.readable)
+ }\n writable: ${inspect(this.writable)}\n}`;
}
}
diff --git a/cli/js/web/streams/transform_stream_default_controller.ts b/cli/js/web/streams/transform_stream_default_controller.ts
index 22087fb0b..54f1e9f2d 100644
--- a/cli/js/web/streams/transform_stream_default_controller.ts
+++ b/cli/js/web/streams/transform_stream_default_controller.ts
@@ -24,7 +24,7 @@ export class TransformStreamDefaultControllerImpl<I = any, O = any>
private constructor() {
throw new TypeError(
- "TransformStreamDefaultController's constructor cannot be called."
+ "TransformStreamDefaultController's constructor cannot be called.",
);
}
@@ -36,7 +36,7 @@ export class TransformStreamDefaultControllerImpl<I = any, O = any>
sym.readable
][sym.readableStreamController];
return readableStreamDefaultControllerGetDesiredSize(
- readableController as ReadableStreamDefaultControllerImpl<O>
+ readableController as ReadableStreamDefaultControllerImpl<O>,
);
}
@@ -63,13 +63,13 @@ export class TransformStreamDefaultControllerImpl<I = any, O = any>
}
[customInspect](): string {
- return `${this.constructor.name} { desiredSize: ${String(
- this.desiredSize
- )} }`;
+ return `${this.constructor.name} { desiredSize: ${
+ String(this.desiredSize)
+ } }`;
}
}
setFunctionName(
TransformStreamDefaultControllerImpl,
- "TransformStreamDefaultController"
+ "TransformStreamDefaultController",
);
diff --git a/cli/js/web/streams/writable_stream.ts b/cli/js/web/streams/writable_stream.ts
index 2dea5311b..94bedb941 100644
--- a/cli/js/web/streams/writable_stream.ts
+++ b/cli/js/web/streams/writable_stream.ts
@@ -36,7 +36,7 @@ export class WritableStreamImpl<W = any> implements WritableStream<W> {
constructor(
underlyingSink: UnderlyingSink = {},
- strategy: QueuingStrategy = {}
+ strategy: QueuingStrategy = {},
) {
initializeWritableStream(this);
const size = strategy.size;
@@ -51,7 +51,7 @@ export class WritableStreamImpl<W = any> implements WritableStream<W> {
this,
underlyingSink,
highWaterMark,
- sizeAlgorithm
+ sizeAlgorithm,
);
}
@@ -69,7 +69,7 @@ export class WritableStreamImpl<W = any> implements WritableStream<W> {
}
if (isWritableStreamLocked(this)) {
return Promise.reject(
- new TypeError("Cannot abort a locked WritableStream.")
+ new TypeError("Cannot abort a locked WritableStream."),
);
}
return writableStreamAbort(this, reason);
@@ -81,12 +81,12 @@ export class WritableStreamImpl<W = any> implements WritableStream<W> {
}
if (isWritableStreamLocked(this)) {
return Promise.reject(
- new TypeError("Cannot abort a locked WritableStream.")
+ new TypeError("Cannot abort a locked WritableStream."),
);
}
if (writableStreamCloseQueuedOrInFlight(this)) {
return Promise.reject(
- new TypeError("Cannot close an already closing WritableStream.")
+ new TypeError("Cannot close an already closing WritableStream."),
);
}
return writableStreamClose(this);
diff --git a/cli/js/web/streams/writable_stream_default_controller.ts b/cli/js/web/streams/writable_stream_default_controller.ts
index 0fe5f7ef9..960060b8f 100644
--- a/cli/js/web/streams/writable_stream_default_controller.ts
+++ b/cli/js/web/streams/writable_stream_default_controller.ts
@@ -30,7 +30,7 @@ export class WritableStreamDefaultControllerImpl<W>
private constructor() {
throw new TypeError(
- "WritableStreamDefaultController's constructor cannot be called."
+ "WritableStreamDefaultController's constructor cannot be called.",
);
}
@@ -64,5 +64,5 @@ export class WritableStreamDefaultControllerImpl<W>
setFunctionName(
WritableStreamDefaultControllerImpl,
- "WritableStreamDefaultController"
+ "WritableStreamDefaultController",
);
diff --git a/cli/js/web/streams/writable_stream_default_writer.ts b/cli/js/web/streams/writable_stream_default_writer.ts
index 2e19af923..34e664e95 100644
--- a/cli/js/web/streams/writable_stream_default_writer.ts
+++ b/cli/js/web/streams/writable_stream_default_writer.ts
@@ -68,7 +68,7 @@ export class WritableStreamDefaultWriterImpl<W>
get closed(): Promise<void> {
if (!isWritableStreamDefaultWriter(this)) {
return Promise.reject(
- new TypeError("Invalid WritableStreamDefaultWriter.")
+ new TypeError("Invalid WritableStreamDefaultWriter."),
);
}
return this[sym.closedPromise].promise;
@@ -87,7 +87,7 @@ export class WritableStreamDefaultWriterImpl<W>
get ready(): Promise<void> {
if (!isWritableStreamDefaultWriter(this)) {
return Promise.reject(
- new TypeError("Invalid WritableStreamDefaultWriter.")
+ new TypeError("Invalid WritableStreamDefaultWriter."),
);
}
return this[sym.readyPromise].promise;
@@ -97,12 +97,12 @@ export class WritableStreamDefaultWriterImpl<W>
abort(reason: any): Promise<void> {
if (!isWritableStreamDefaultWriter(this)) {
return Promise.reject(
- new TypeError("Invalid WritableStreamDefaultWriter.")
+ new TypeError("Invalid WritableStreamDefaultWriter."),
);
}
if (!this[sym.ownerWritableStream]) {
Promise.reject(
- new TypeError("WritableStreamDefaultWriter has no owner.")
+ new TypeError("WritableStreamDefaultWriter has no owner."),
);
}
return writableStreamDefaultWriterAbort(this, reason);
@@ -111,18 +111,18 @@ export class WritableStreamDefaultWriterImpl<W>
close(): Promise<void> {
if (!isWritableStreamDefaultWriter(this)) {
return Promise.reject(
- new TypeError("Invalid WritableStreamDefaultWriter.")
+ new TypeError("Invalid WritableStreamDefaultWriter."),
);
}
const stream = this[sym.ownerWritableStream];
if (!stream) {
Promise.reject(
- new TypeError("WritableStreamDefaultWriter has no owner.")
+ new TypeError("WritableStreamDefaultWriter has no owner."),
);
}
if (writableStreamCloseQueuedOrInFlight(stream)) {
Promise.reject(
- new TypeError("Stream is in an invalid state to be closed.")
+ new TypeError("Stream is in an invalid state to be closed."),
);
}
return writableStreamDefaultWriterClose(this);
@@ -143,21 +143,21 @@ export class WritableStreamDefaultWriterImpl<W>
write(chunk: W): Promise<void> {
if (!isWritableStreamDefaultWriter(this)) {
return Promise.reject(
- new TypeError("Invalid WritableStreamDefaultWriter.")
+ new TypeError("Invalid WritableStreamDefaultWriter."),
);
}
if (!this[sym.ownerWritableStream]) {
Promise.reject(
- new TypeError("WritableStreamDefaultWriter has no owner.")
+ new TypeError("WritableStreamDefaultWriter has no owner."),
);
}
return writableStreamDefaultWriterWrite(this, chunk);
}
[customInspect](): string {
- return `${this.constructor.name} { closed: Promise, desiredSize: ${String(
- this.desiredSize
- )}, ready: Promise }`;
+ return `${this.constructor.name} { closed: Promise, desiredSize: ${
+ String(this.desiredSize)
+ }, ready: Promise }`;
}
}
diff --git a/cli/js/web/text_encoding.ts b/cli/js/web/text_encoding.ts
index d225c6928..97848cb77 100644
--- a/cli/js/web/text_encoding.ts
+++ b/cli/js/web/text_encoding.ts
@@ -105,7 +105,7 @@ export function atob(s: string): string {
if (rem === 1 || /[^+/0-9A-Za-z]/.test(s)) {
throw new DOMException(
"The string to be decoded is not correctly encoded",
- "DataDecodeError"
+ "DataDecodeError",
);
}
@@ -129,7 +129,7 @@ export function btoa(s: string): string {
if (charCode > 0xff) {
throw new TypeError(
"The string to be encoded contains characters " +
- "outside of the Latin1 range."
+ "outside of the Latin1 range.",
);
}
byteArray.push(charCode);
@@ -157,7 +157,7 @@ class SingleByteDecoder implements Decoder {
constructor(
index: number[],
- { ignoreBOM = false, fatal = false }: DecoderOptions = {}
+ { ignoreBOM = false, fatal = false }: DecoderOptions = {},
) {
if (ignoreBOM) {
throw new TypeError("Ignoring the BOM is available only with utf-8.");
@@ -222,7 +222,7 @@ const decoders = new Map<string, (options: DecoderOptions) => Decoder>();
// Single byte decoders are an array of code point lookups
const encodingIndexes = new Map<string, number[]>();
-// prettier-ignore
+// deno-fmt-ignore
encodingIndexes.set("windows-1252", [
8364,
129,
@@ -358,7 +358,7 @@ for (const [key, index] of encodingIndexes) {
key,
(options: DecoderOptions): SingleByteDecoder => {
return new SingleByteDecoder(index, options);
- }
+ },
);
}
@@ -442,7 +442,7 @@ export class TextDecoder {
const encoding = encodings.get(label);
if (!encoding) {
throw new RangeError(
- `The encoding label provided ('${label}') is invalid.`
+ `The encoding label provided ('${label}') is invalid.`,
);
}
if (!decoders.has(encoding) && encoding !== "utf-8") {
@@ -453,7 +453,7 @@ export class TextDecoder {
decode(
input?: BufferSource,
- options: TextDecodeOptions = { stream: false }
+ options: TextDecodeOptions = { stream: false },
): string {
if (options.stream) {
throw new TypeError("Stream not supported.");
diff --git a/cli/js/web/timers.ts b/cli/js/web/timers.ts
index e8eacb402..71aef5f85 100644
--- a/cli/js/web/timers.ts
+++ b/cli/js/web/timers.ts
@@ -149,7 +149,7 @@ function unschedule(timer: Timer): void {
const nextDueNode: DueNode | null = dueTree.min();
setOrClearGlobalTimeout(
nextDueNode && nextDueNode.due,
- OriginalDate.now()
+ OriginalDate.now(),
);
}
} else {
@@ -203,7 +203,7 @@ function setTimer(
cb: (...args: Args) => void,
delay: number,
args: Args,
- repeat: boolean
+ repeat: boolean,
): number {
// Bind `args` to the callback and bind `this` to globalThis(global).
const callback: () => void = cb.bind(globalThis, ...args);
@@ -215,7 +215,7 @@ function setTimer(
console.warn(
`${delay} does not fit into` +
" a 32-bit signed integer." +
- "\nTimeout duration was set to 1."
+ "\nTimeout duration was set to 1.",
);
delay = 1;
}
diff --git a/cli/js/web/url.ts b/cli/js/web/url.ts
index 544168d80..f466f9583 100644
--- a/cli/js/web/url.ts
+++ b/cli/js/web/url.ts
@@ -86,14 +86,14 @@ function parse(url: string, isBase = true): URLParts | undefined {
[restAuthentication, restAuthority] = takePattern(restAuthority, /^(.*)@/);
[parts.username, restAuthentication] = takePattern(
restAuthentication,
- /^([^:]*)/
+ /^([^:]*)/,
);
parts.username = encodeUserinfo(parts.username);
[parts.password] = takePattern(restAuthentication, /^:(.*)/);
parts.password = encodeUserinfo(parts.password);
[parts.hostname, restAuthority] = takePattern(
restAuthority,
- /^(\[[0-9a-fA-F.:]{2,}\]|[^:]+)/
+ /^(\[[0-9a-fA-F.:]{2,}\]|[^:]+)/,
);
[parts.port] = takePattern(restAuthority, /^:(.*)/);
if (!isValidPort(parts.port)) {
@@ -122,8 +122,7 @@ function parse(url: string, isBase = true): URLParts | undefined {
function generateUUID(): string {
return "00000000-0000-4000-8000-000000000000".replace(/[0]/g, (): string =>
// random integer from 0 to 15 as a hex digit.
- (getRandomValues(new Uint8Array(1))[0] % 16).toString(16)
- );
+ (getRandomValues(new Uint8Array(1))[0] % 16).toString(16));
}
// Keep it outside of URL to avoid any attempts of access.
@@ -174,7 +173,7 @@ function normalizePath(path: string, isFilePath = false): string {
function resolvePathFromBase(
path: string,
basePath: string,
- isFilePath = false
+ isFilePath = false,
): string {
let normalizedPath = normalizePath(path, isFilePath);
let normalizedBasePath = normalizePath(basePath, isFilePath);
@@ -185,11 +184,11 @@ function resolvePathFromBase(
let baseDriveLetter: string;
[driveLetter, normalizedPath] = takePattern(
normalizedPath,
- /^(\/[A-Za-z]:)(?=\/)/
+ /^(\/[A-Za-z]:)(?=\/)/,
);
[baseDriveLetter, normalizedBasePath] = takePattern(
normalizedBasePath,
- /^(\/[A-Za-z]:)(?=\/)/
+ /^(\/[A-Za-z]:)(?=\/)/,
);
driveLetterPrefix = driveLetter || baseDriveLetter;
}
@@ -306,10 +305,9 @@ export class URLImpl implements URL {
}
get href(): string {
- const authentication =
- this.username || this.password
- ? `${this.username}${this.password ? ":" + this.password : ""}@`
- : "";
+ const authentication = this.username || this.password
+ ? `${this.username}${this.password ? ":" + this.password : ""}@`
+ : "";
const host = this.host;
const slashes = host ? "//" : parts.get(this)!.slashes;
let pathname = this.pathname;
@@ -421,8 +419,9 @@ export class URLImpl implements URL {
}
}
- const urlParts =
- typeof url === "string" ? parse(url, !baseParts) : parts.get(url);
+ const urlParts = typeof url === "string"
+ ? parse(url, !baseParts)
+ : parts.get(url);
if (urlParts == undefined) {
throw new TypeError("Invalid URL.");
}
@@ -441,7 +440,7 @@ export class URLImpl implements URL {
path: resolvePathFromBase(
urlParts.path,
baseParts.path || "/",
- baseParts.protocol == "file"
+ baseParts.protocol == "file",
),
query: urlParts.query,
hash: urlParts.hash,
@@ -522,28 +521,28 @@ function charInC0ControlSet(c: string): boolean {
}
function charInSearchSet(c: string): boolean {
- // prettier-ignore
+ // deno-fmt-ignore
return charInC0ControlSet(c) || ["\u0020", "\u0022", "\u0023", "\u0027", "\u003C", "\u003E"].includes(c) || c > "\u007E";
}
function charInFragmentSet(c: string): boolean {
- // prettier-ignore
+ // deno-fmt-ignore
return charInC0ControlSet(c) || ["\u0020", "\u0022", "\u003C", "\u003E", "\u0060"].includes(c);
}
function charInPathSet(c: string): boolean {
- // prettier-ignore
+ // deno-fmt-ignore
return charInFragmentSet(c) || ["\u0023", "\u003F", "\u007B", "\u007D"].includes(c);
}
function charInUserinfoSet(c: string): boolean {
// "\u0027" ("'") seemingly isn't in the spec, but matches Chrome and Firefox.
- // prettier-ignore
+ // deno-fmt-ignore
return charInPathSet(c) || ["\u0027", "\u002F", "\u003A", "\u003B", "\u003D", "\u0040", "\u005B", "\u005C", "\u005D", "\u005E", "\u007C"].includes(c);
}
function charIsForbiddenInHost(c: string): boolean {
- // prettier-ignore
+ // deno-fmt-ignore
return ["\u0000", "\u0009", "\u000A", "\u000D", "\u0020", "\u0023", "\u0025", "\u002F", "\u003A", "\u003C", "\u003E", "\u003F", "\u0040", "\u005B", "\u005C", "\u005D", "\u005E"].includes(c);
}
@@ -591,8 +590,9 @@ function encodeHostname(s: string, isSpecial = true): string {
if (result.match(/%(?![0-9A-Fa-f]{2})/) != null) {
throw new TypeError("Invalid hostname.");
}
- result = result.replace(/%(.{2})/g, (_, hex) =>
- String.fromCodePoint(Number(`0x${hex}`))
+ result = result.replace(
+ /%(.{2})/g,
+ (_, hex) => String.fromCodePoint(Number(`0x${hex}`)),
);
// IDNA domain to ASCII.
diff --git a/cli/js/web/url_search_params.ts b/cli/js/web/url_search_params.ts
index b4d199fbc..f3e247522 100644
--- a/cli/js/web/url_search_params.ts
+++ b/cli/js/web/url_search_params.ts
@@ -57,14 +57,14 @@ export class URLSearchParamsImpl implements URLSearchParams {
};
#handleArrayInitialization = (
- init: string[][] | Iterable<[string, string]>
+ init: string[][] | Iterable<[string, string]>,
): void => {
// Overload: sequence<sequence<USVString>>
for (const tuple of init) {
// If pair does not contain exactly two items, then throw a TypeError.
if (tuple.length !== 2) {
throw new TypeError(
- "URLSearchParams.constructor tuple array argument must only contain pair elements"
+ "URLSearchParams.constructor tuple array argument must only contain pair elements",
);
}
this.#append(tuple[0], tuple[1]);
@@ -175,7 +175,7 @@ export class URLSearchParamsImpl implements URLSearchParams {
forEach(
callbackfn: (value: string, key: string, parent: this) => void,
// eslint-disable-next-line @typescript-eslint/no-explicit-any
- thisArg?: any
+ thisArg?: any,
): void {
requiredArguments("URLSearchParams.forEach", arguments.length, 1);
@@ -212,7 +212,7 @@ export class URLSearchParamsImpl implements URLSearchParams {
return this.#params
.map(
(tuple) =>
- `${encodeURIComponent(tuple[0])}=${encodeURIComponent(tuple[1])}`
+ `${encodeURIComponent(tuple[0])}=${encodeURIComponent(tuple[1])}`,
)
.join("&");
}
diff --git a/cli/js/web/util.ts b/cli/js/web/util.ts
index 281048cd8..3165c37a7 100644
--- a/cli/js/web/util.ts
+++ b/cli/js/web/util.ts
@@ -27,7 +27,7 @@ export function isInvalidDate(x: Date): boolean {
export function requiredArguments(
name: string,
length: number,
- required: number
+ required: number,
): void {
if (length < required) {
const errMsg = `${name} requires at least ${required} argument${
@@ -43,7 +43,7 @@ export function immutableDefine(
o: any,
p: string | number | symbol,
// eslint-disable-next-line @typescript-eslint/no-explicit-any
- value: any
+ value: any,
): void {
Object.defineProperty(o, p, {
value,
@@ -64,7 +64,7 @@ export function hasOwnProperty(obj: unknown, v: PropertyKey): boolean {
*
* @internal */
export function isIterable<T, P extends keyof T, K extends T[P]>(
- o: T
+ o: T,
): o is T & Iterable<[P, K]> {
// checks for null and undefined
if (o == null) {
@@ -81,12 +81,12 @@ function cloneArrayBuffer(
srcBuffer: ArrayBufferLike,
srcByteOffset: number,
srcLength: number,
- cloneConstructor: ArrayBufferConstructor | SharedArrayBufferConstructor
+ cloneConstructor: ArrayBufferConstructor | SharedArrayBufferConstructor,
): InstanceType<typeof cloneConstructor> {
// this function fudges the return type but SharedArrayBuffer is disabled for a while anyway
return srcBuffer.slice(
srcByteOffset,
- srcByteOffset + srcLength
+ srcByteOffset + srcLength,
) as InstanceType<typeof cloneConstructor>;
}
@@ -122,7 +122,7 @@ export function cloneValue(value: any): any {
value,
0,
value.byteLength,
- ArrayBuffer
+ ArrayBuffer,
);
objectCloneMemo.set(value, cloned);
return cloned;
@@ -142,7 +142,7 @@ export function cloneValue(value: any): any {
return new (value.constructor as DataViewConstructor)(
clonedBuffer,
value.byteOffset,
- length
+ length,
);
}
if (value instanceof Map) {
@@ -183,7 +183,7 @@ interface GenericConstructor<T = any> {
* are not. */
export function defineEnumerableProps(
Ctor: GenericConstructor,
- props: string[]
+ props: string[],
): void {
for (const prop of props) {
Reflect.defineProperty(Ctor.prototype, prop, { enumerable: true });
diff --git a/cli/js/web/workers.ts b/cli/js/web/workers.ts
index cc40f104c..5fd63477a 100644
--- a/cli/js/web/workers.ts
+++ b/cli/js/web/workers.ts
@@ -94,7 +94,7 @@ export class WorkerImpl extends EventTarget implements Worker {
if (type !== "module") {
throw new Error(
- 'Not yet implemented: only "module" type workers are supported'
+ 'Not yet implemented: only "module" type workers are supported',
);
}
@@ -125,7 +125,7 @@ export class WorkerImpl extends EventTarget implements Worker {
hasSourceCode,
sourceCode,
useDenoNamespace,
- options?.name
+ options?.name,
);
this.#id = id;
this.#poll();
@@ -225,7 +225,7 @@ export class WorkerImpl extends EventTarget implements Worker {
postMessage(message: any, transferOrOptions?: any): void {
if (transferOrOptions) {
throw new Error(
- "Not yet implemented: `transfer` and `options` are not supported."
+ "Not yet implemented: `transfer` and `options` are not supported.",
);
}
diff --git a/cli/js/write_file.ts b/cli/js/write_file.ts
index 6b64bc09d..db5f20238 100644
--- a/cli/js/write_file.ts
+++ b/cli/js/write_file.ts
@@ -15,7 +15,7 @@ export interface WriteFileOptions {
export function writeFileSync(
path: string | URL,
data: Uint8Array,
- options: WriteFileOptions = {}
+ options: WriteFileOptions = {},
): void {
if (options.create !== undefined) {
const create = !!options.create;
@@ -45,7 +45,7 @@ export function writeFileSync(
export async function writeFile(
path: string | URL,
data: Uint8Array,
- options: WriteFileOptions = {}
+ options: WriteFileOptions = {},
): Promise<void> {
if (options.create !== undefined) {
const create = !!options.create;
diff --git a/cli/js/write_text_file.ts b/cli/js/write_text_file.ts
index ca7646c75..97148c411 100644
--- a/cli/js/write_text_file.ts
+++ b/cli/js/write_text_file.ts
@@ -4,7 +4,7 @@ import { writeFileSync, writeFile, WriteFileOptions } from "./write_file.ts";
export function writeTextFileSync(
path: string | URL,
data: string,
- options: WriteFileOptions = {}
+ options: WriteFileOptions = {},
): void {
const encoder = new TextEncoder();
return writeFileSync(path, encoder.encode(data), options);
@@ -13,7 +13,7 @@ export function writeTextFileSync(
export function writeTextFile(
path: string | URL,
data: string,
- options: WriteFileOptions = {}
+ options: WriteFileOptions = {},
): Promise<void> {
const encoder = new TextEncoder();
return writeFile(path, encoder.encode(data), options);