diff options
Diffstat (limited to 'stdlib/source/library/lux/world/file/watch.lux')
| -rw-r--r-- | stdlib/source/library/lux/world/file/watch.lux | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/stdlib/source/library/lux/world/file/watch.lux b/stdlib/source/library/lux/world/file/watch.lux index bfe64cca1..5800e68e1 100644 --- a/stdlib/source/library/lux/world/file/watch.lux +++ b/stdlib/source/library/lux/world/file/watch.lux @@ -149,7 +149,7 @@ (List //.Path)]]))) (do {! (try.with async.monad)} [current_files (..poll_files fs directory) - #let [creations (if (..creation? concern) + .let [creations (if (..creation? concern) (list.only (|>> product.left (dictionary.key? file_tracker) not) current_files) (list)) @@ -236,7 +236,7 @@ (dictionary.of_list text.hash)) tracker))] (in (#try.Success []))) - #let [[creations modifications deletions] + .let [[creations modifications deletions] (list\fold (function (_ [_ [creations modifications deletions]] [all_creations all_modifications all_deletions]) [(list\compose creations all_creations) @@ -378,7 +378,7 @@ [valid? (java/nio/file/WatchKey::reset key)] (if valid? (do ! - [#let [path (|> key + [.let [path (|> key java/nio/file/WatchKey::watchable (:as java/nio/file/Path) java/nio/file/Path::toString @@ -410,7 +410,7 @@ (do (try.with io.monad) [watcher (java/nio/file/FileSystem::newWatchService (java/nio/file/FileSystems::getDefault)) - #let [tracker (stm.var (: (Dictionary //.Path [Concern java/nio/file/WatchKey]) + .let [tracker (stm.var (: (Dictionary //.Path [Concern java/nio/file/WatchKey]) (dictionary.empty text.hash))) stop (: (-> //.Path (Async (Try Concern))) |