mirror of
https://github.com/denoland/deno.git
synced 2024-12-22 15:24:46 -05:00
2aed322dd5
This commit rewrites most of the ops to use "serde_v8" instead of "json" serialization.
56 lines
1.3 KiB
JavaScript
56 lines
1.3 KiB
JavaScript
// Copyright 2018-2021 the Deno authors. All rights reserved. MIT license.
|
|
"use strict";
|
|
|
|
((window) => {
|
|
const core = window.Deno.core;
|
|
const { errors } = window.__bootstrap.errors;
|
|
|
|
class FsWatcher {
|
|
#rid = 0;
|
|
|
|
constructor(paths, options) {
|
|
const { recursive } = options;
|
|
this.#rid = core.jsonOpSync("op_fs_events_open", { recursive, paths });
|
|
}
|
|
|
|
get rid() {
|
|
return this.#rid;
|
|
}
|
|
|
|
async next() {
|
|
try {
|
|
const value = await core.jsonOpAsync("op_fs_events_poll", this.rid);
|
|
return value
|
|
? { value, done: false }
|
|
: { value: undefined, done: true };
|
|
} catch (error) {
|
|
if (error instanceof errors.BadResource) {
|
|
return { value: undefined, done: true };
|
|
} else if (error instanceof errors.Interrupted) {
|
|
return { value: undefined, done: true };
|
|
}
|
|
throw error;
|
|
}
|
|
}
|
|
|
|
return(value) {
|
|
core.close(this.rid);
|
|
return Promise.resolve({ value, done: true });
|
|
}
|
|
|
|
[Symbol.asyncIterator]() {
|
|
return this;
|
|
}
|
|
}
|
|
|
|
function watchFs(
|
|
paths,
|
|
options = { recursive: true },
|
|
) {
|
|
return new FsWatcher(Array.isArray(paths) ? paths : [paths], options);
|
|
}
|
|
|
|
window.__bootstrap.fsEvents = {
|
|
watchFs,
|
|
};
|
|
})(this);
|