diff options
Diffstat (limited to 'stdlib/source/library/lux/world/file/watch.lux')
| -rw-r--r-- | stdlib/source/library/lux/world/file/watch.lux | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/stdlib/source/library/lux/world/file/watch.lux b/stdlib/source/library/lux/world/file/watch.lux index a3026e8e8..edc65be2f 100644 --- a/stdlib/source/library/lux/world/file/watch.lux +++ b/stdlib/source/library/lux/world/file/watch.lux @@ -123,11 +123,11 @@ (def: (file_tracker fs directory) (-> (//.System Async) //.Path (Async (Try File_Tracker))) (do [! (try.with async.monad)] - [files (# fs directory_files directory)] + [files (at fs directory_files directory)] (monad.mix ! (function (_ file tracker) (do ! - [last_modified (# fs last_modified file)] + [last_modified (at fs last_modified file)] (in (dictionary.has file last_modified tracker)))) (is File_Tracker (dictionary.empty text.hash)) @@ -136,11 +136,11 @@ (def: (available_files fs directory) (-> (//.System Async) //.Path (Async (Try (List [//.Path Instant])))) (do [! (try.with async.monad)] - [files (# fs directory_files directory)] + [files (at fs directory_files directory)] (monad.each ! (function (_ file) (|> file - (# fs last_modified) - (# ! each (|>> [file])))) + (at fs last_modified) + (at ! each (|>> [file])))) files))) (def: (available_directory_changes fs [directory [the_concern file_tracker]]) @@ -191,7 +191,7 @@ (implementation (def: (start new_concern path) (do [! async.monad] - [exists? (# fs directory? path)] + [exists? (at fs directory? path)] (if exists? (do ! [updated? (stm.commit! (..update_watch! new_concern path tracker))] @@ -336,9 +336,9 @@ (def: default_key_concern (-> java/nio/file/WatchKey (IO Concern)) (|>> java/nio/file/WatchKey::pollEvents - (# io.monad each (|>> ..default_list - (list#each default_event_concern) - (list#mix ..also ..none))))) + (at io.monad each (|>> ..default_list + (list#each default_event_concern) + (list#mix ..also ..none))))) (import: java/nio/file/WatchService "[1]::[0]" |