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