summaryrefslogtreecommitdiff
path: root/cli/js/ops/fs_events.ts
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2020-07-19 19:49:44 +0200
committerGitHub <noreply@github.com>2020-07-19 19:49:44 +0200
commitfa61956f03491101b6ef64423ea2f1f73af26a73 (patch)
treec3800702071ca78aa4dd71bdd0a59a9bbe460bdd /cli/js/ops/fs_events.ts
parent53adde866dd399aa2509d14508642fce37afb8f5 (diff)
Port internal TS code to JS (#6793)
Co-authored-by: Ryan Dahl <ry@tinyclouds.org>
Diffstat (limited to 'cli/js/ops/fs_events.ts')
-rw-r--r--cli/js/ops/fs_events.ts44
1 files changed, 0 insertions, 44 deletions
diff --git a/cli/js/ops/fs_events.ts b/cli/js/ops/fs_events.ts
deleted file mode 100644
index ffe19b4d7..000000000
--- a/cli/js/ops/fs_events.ts
+++ /dev/null
@@ -1,44 +0,0 @@
-// Copyright 2018-2020 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[];
-}
-
-interface FsWatcherOptions {
- recursive: boolean;
-}
-
-class FsWatcher implements AsyncIterableIterator<FsEvent> {
- readonly rid: number;
-
- constructor(paths: string[], options: FsWatcherOptions) {
- 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: FsWatcherOptions = { recursive: true },
-): AsyncIterableIterator<FsEvent> {
- return new FsWatcher(Array.isArray(paths) ? paths : [paths], options);
-}