diff options
Diffstat (limited to 'stdlib/source/library/lux/control/concurrency/actor.lux')
| -rw-r--r-- | stdlib/source/library/lux/control/concurrency/actor.lux | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/stdlib/source/library/lux/control/concurrency/actor.lux b/stdlib/source/library/lux/control/concurrency/actor.lux index b1d80473c..c4dd58b5e 100644 --- a/stdlib/source/library/lux/control/concurrency/actor.lux +++ b/stdlib/source/library/lux/control/concurrency/actor.lux @@ -55,8 +55,8 @@ [current (async.value read)] (case current {.#Some [head tail]} - (# ! each (|>> {.#Item head}) - (pending tail)) + (at ! each (|>> {.#Item head}) + (pending tail)) {.#None} (in {.#End})))) @@ -111,13 +111,13 @@ (let [[obituary _] (the #obituary (representation actor))] (|> obituary async.value - (# io.functor each - (|>> (pipe.case - {.#None} - bit.yes + (at io.functor each + (|>> (pipe.case + {.#None} + bit.yes - _ - bit.no)))))) + _ + bit.no)))))) (def: .public (obituary' actor) (All (_ s) (-> (Actor s) (IO (Maybe (Obituary s))))) @@ -214,7 +214,7 @@ (def: actor_decl^ (Parser [Text (List Text)]) (<>.either (<code>.form (<>.and <code>.local (<>.some <code>.local))) - (<>.and <code>.local (# <>.monad in (list))))) + (<>.and <code>.local (at <>.monad in (list))))) (type: On_MailC [[Text Text Text] Code]) @@ -306,7 +306,7 @@ (def: reference^ (Parser [Symbol (List Text)]) (<>.either (<code>.form (<>.and <code>.symbol (<>.some <code>.local))) - (<>.and <code>.symbol (# <>.monad in (list))))) + (<>.and <code>.symbol (at <>.monad in (list))))) (def: messageP (Parser [Code Signature Code Code]) @@ -361,6 +361,6 @@ (if continue? (|> actor (..mail! (action event stop)) - (# ! each try.maybe)) + (at ! each try.maybe)) (in {.#None})))) channel))) |