mirror of
https://github.com/denoland/deno.git
synced 2024-11-26 16:09:27 -05:00
39 lines
1.1 KiB
TypeScript
39 lines
1.1 KiB
TypeScript
// Copyright 2019 the Deno authors. All rights reserved. MIT license.
|
|
import { sendSync, sendAsync } from "./dispatch_json.ts";
|
|
import { close } from "./resources.ts";
|
|
|
|
export interface FsEvent {
|
|
kind: "any" | "access" | "create" | "modify" | "remove";
|
|
paths: string[];
|
|
}
|
|
|
|
class FsWatcher implements AsyncIterableIterator<FsEvent> {
|
|
readonly rid: number;
|
|
|
|
constructor(paths: string[], options: { recursive: boolean }) {
|
|
const { recursive } = options;
|
|
this.rid = sendSync("op_fs_events_open", { recursive, paths });
|
|
}
|
|
|
|
next(): Promise<IteratorResult<FsEvent>> {
|
|
return sendAsync("op_fs_events_poll", {
|
|
rid: this.rid,
|
|
});
|
|
}
|
|
|
|
return(value?: FsEvent): Promise<IteratorResult<FsEvent>> {
|
|
close(this.rid);
|
|
return Promise.resolve({ value, done: true });
|
|
}
|
|
|
|
[Symbol.asyncIterator](): AsyncIterableIterator<FsEvent> {
|
|
return this;
|
|
}
|
|
}
|
|
|
|
export function watchFs(
|
|
paths: string | string[],
|
|
options = { recursive: true }
|
|
): AsyncIterableIterator<FsEvent> {
|
|
return new FsWatcher(Array.isArray(paths) ? paths : [paths], options);
|
|
}
|