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/js2/40_fs_events.js | |
| parent | 53adde866dd399aa2509d14508642fce37afb8f5 (diff) | |
Port internal TS code to JS (#6793)
Co-authored-by: Ryan Dahl <ry@tinyclouds.org>
Diffstat (limited to 'cli/js2/40_fs_events.js')
| -rw-r--r-- | cli/js2/40_fs_events.js | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/cli/js2/40_fs_events.js b/cli/js2/40_fs_events.js new file mode 100644 index 000000000..ad1fd678f --- /dev/null +++ b/cli/js2/40_fs_events.js @@ -0,0 +1,45 @@ +// Copyright 2018-2020 the Deno authors. All rights reserved. MIT license. + +((window) => { + const { sendSync, sendAsync } = window.__bootstrap.dispatchJson; + const { close } = window.__bootstrap.resources; + + class FsWatcher { + #rid = 0; + + constructor(paths, options) { + const { recursive } = options; + this.#rid = sendSync("op_fs_events_open", { recursive, paths }); + } + + get rid() { + return this.#rid; + } + + next() { + return sendAsync("op_fs_events_poll", { + rid: this.rid, + }); + } + + return(value) { + 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); |
