diff options
author | Bartek IwaĆczuk <biwanczuk@gmail.com> | 2020-07-19 19:49:44 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-07-19 19:49:44 +0200 |
commit | fa61956f03491101b6ef64423ea2f1f73af26a73 (patch) | |
tree | c3800702071ca78aa4dd71bdd0a59a9bbe460bdd /cli/js/ops/fs_events.ts | |
parent | 53adde866dd399aa2509d14508642fce37afb8f5 (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.ts | 44 |
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); -} |