diff options
Diffstat (limited to 'stdlib/source/test/lux/world/file/watch.lux')
| -rw-r--r-- | stdlib/source/test/lux/world/file/watch.lux | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/stdlib/source/test/lux/world/file/watch.lux b/stdlib/source/test/lux/world/file/watch.lux index e8ce8182e..75bcf5a2e 100644 --- a/stdlib/source/test/lux/world/file/watch.lux +++ b/stdlib/source/test/lux/world/file/watch.lux @@ -74,8 +74,8 @@ .let [[fs watcher] (/.mock "/")]] (all _.and (in (do async.monad - [?concern (at watcher concern directory) - ?stop (at watcher stop directory)] + [?concern (of watcher concern directory) + ?stop (of watcher stop directory)] (unit.coverage [/.not_being_watched] (and (when ?concern {try.#Failure error} @@ -94,18 +94,18 @@ (def (no_events_prior_to_creation! fs watcher directory) (-> (//.System Async) (/.Watcher Async) //.Path (Async (Try Bit))) (do [! (try.with async.monad)] - [_ (at fs make_directory directory) - _ (at watcher start /.all directory)] - (|> (at watcher poll []) - (at ! each list.empty?)))) + [_ (of fs make_directory directory) + _ (of watcher start /.all directory)] + (|> (of watcher poll []) + (of ! each list.empty?)))) (def (after_creation! fs watcher expected_path) (-> (//.System Async) (/.Watcher Async) //.Path (Async (Try Bit))) (do (try.with async.monad) [_ (is (Async (Try Any)) (//.make_file async.monad fs (binary.empty 0) expected_path)) - poll/pre (at watcher poll []) - poll/post (at watcher poll [])] + poll/pre (of watcher poll []) + poll/post (of watcher poll [])] (in (and (when poll/pre (list [concern actual_path]) (and (text#= expected_path actual_path) @@ -121,9 +121,9 @@ (-> (//.System Async) (/.Watcher Async) Binary //.Path (Async (Try Bit))) (do (try.with async.monad) [_ (async.after 1 {try.#Success "Delay to make sure the over_write time-stamp always changes."}) - _ (at fs write expected_path data) - poll/2 (at watcher poll []) - poll/2' (at watcher poll [])] + _ (of fs write expected_path data) + poll/2 (of watcher poll []) + poll/2' (of watcher poll [])] (in (and (when poll/2 (list [concern actual_path]) (and (text#= expected_path actual_path) @@ -138,9 +138,9 @@ (def (after_deletion! fs watcher expected_path) (-> (//.System Async) (/.Watcher Async) //.Path (Async (Try Bit))) (do (try.with async.monad) - [_ (at fs delete expected_path) - poll/3 (at watcher poll []) - poll/3' (at watcher poll [])] + [_ (of fs delete expected_path) + poll/3 (of watcher poll []) + poll/3' (of watcher poll [])] (in (and (when poll/3 (list [concern actual_path]) (and (not (/.creation? concern)) @@ -164,7 +164,7 @@ [directory (random.alphabetic 5) .let [/ "/" [fs watcher] (/.mock /)] - expected_path (at ! each (|>> (format directory /)) + expected_path (of ! each (|>> (format directory /)) (random.alphabetic 5)) data ($binary.random 10)] (in (do [! async.monad] @@ -191,7 +191,7 @@ .let [/ "/" [fs watcher] (/.mock /)]] (in (do async.monad - [started? (at watcher start /.all directory)] + [started? (of watcher start /.all directory)] (unit.coverage [/.cannot_poll_a_non_existent_directory] (when started? {try.#Success _} |