diff options
author | Bartek IwaĆczuk <biwanczuk@gmail.com> | 2020-03-08 13:09:22 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-03-08 13:09:22 +0100 |
commit | 1b6f8318750d319d689f7eeef9e7e1f2e56b94a6 (patch) | |
tree | b2e182b77cfbcd25ee893113de9f61509e16e787 /cli/js/ops/fs_events.ts | |
parent | b9037c86ed8d1d55a59a1c1298fa12bbfcae6873 (diff) |
reorg: move JS ops implementations to cli/js/ops/, part 1 (#4264)
Following JS ops were moved to separate files in cli/js/ops directory:
- compiler
- dispatch_json
- dispatch_minimal
- errors
- fetch
- fs_events
- os
- random
- repl
- resources
- runtime_compiler
- runtime
- tty
Diffstat (limited to 'cli/js/ops/fs_events.ts')
-rw-r--r-- | cli/js/ops/fs_events.ts | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/cli/js/ops/fs_events.ts b/cli/js/ops/fs_events.ts new file mode 100644 index 000000000..09e82c515 --- /dev/null +++ b/cli/js/ops/fs_events.ts @@ -0,0 +1,39 @@ +// 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 FsEvents implements AsyncIterableIterator<FsEvent> { + readonly rid: number; + + constructor(paths: string[], options: { recursive: boolean }) { + const { recursive } = options; + this.rid = sendSync("op_fs_events_open", { recursive, paths }); + } + + async next(): Promise<IteratorResult<FsEvent>> { + return await sendAsync("op_fs_events_poll", { + rid: this.rid + }); + } + + async return(value?: FsEvent): Promise<IteratorResult<FsEvent>> { + close(this.rid); + return { value, done: true }; + } + + [Symbol.asyncIterator](): AsyncIterableIterator<FsEvent> { + return this; + } +} + +export function fsEvents( + paths: string | string[], + options = { recursive: true } +): AsyncIterableIterator<FsEvent> { + return new FsEvents(Array.isArray(paths) ? paths : [paths], options); +} |