diff options
Diffstat (limited to 'stdlib/source/lux/control/concurrency')
| -rw-r--r-- | stdlib/source/lux/control/concurrency/actor.lux | 26 | ||||
| -rw-r--r-- | stdlib/source/lux/control/concurrency/frp.lux | 12 | ||||
| -rw-r--r-- | stdlib/source/lux/control/concurrency/stm.lux | 2 |
3 files changed, 20 insertions, 20 deletions
diff --git a/stdlib/source/lux/control/concurrency/actor.lux b/stdlib/source/lux/control/concurrency/actor.lux index 7cd6a8fe1..92cf0207e 100644 --- a/stdlib/source/lux/control/concurrency/actor.lux +++ b/stdlib/source/lux/control/concurrency/actor.lux @@ -4,14 +4,14 @@ [control monad ["p" parser] ["ex" exception (#+ exception:)]] - ["." io (#+ IO io) ("#/." monad)] + ["." io (#+ IO io) ("#;." monad)] [data ["." product] ["." error (#+ Error)] [text format] [collection - ["." list ("#/." monoid monad fold)]]] + ["." list ("#;." monoid monad fold)]]] ["." macro (#+ with-gensyms monad) ["." code] ["s" syntax (#+ syntax: Syntax)] @@ -23,7 +23,7 @@ abstract]] [// ["." atom (#+ Atom atom)] - ["." promise (#+ Promise Resolver) ("#/." monad)]]) + ["." promise (#+ Promise Resolver) ("#;." monad)]]) (exception: #export poisoned) @@ -133,7 +133,7 @@ (#.Some [_ |mailbox|']) (recur |mailbox|'))))) - (io/wrap #0))) + (io;wrap #0))) ) ) @@ -143,7 +143,7 @@ (def: (default-end cause state) (All [s] (-> Text s (Promise Any))) - (promise/wrap [])) + (promise;wrap [])) (def: #export default-behavior (All [s] (Behavior s)) @@ -244,7 +244,7 @@ g!behavior (code.local-identifier (behavior-name _name)) g!actor (code.local-identifier _name) g!new (code.local-identifier (new-name _name)) - g!vars (list/map code.local-identifier _vars)]] + g!vars (list;map code.local-identifier _vars)]] (wrap (list (` (type: (~+ (csw.export export)) ((~ g!type) (~+ g!vars)) (~ state-type))) (` (type: (~+ (csw.export export)) ((~ g!actor) (~+ g!vars)) @@ -334,24 +334,24 @@ #let [message-name [current-module (get@ #name signature)] g!type (code.identifier (product.both function.identity state-name actor-name)) g!message (code.local-identifier (get@ #name signature)) - g!actor-vars (list/map code.local-identifier actor-vars) + g!actor-vars (list;map code.local-identifier actor-vars) actorC (` ((~ (code.identifier actor-name)) (~+ g!actor-vars))) - g!all-vars (|> (get@ #vars signature) (list/map code.local-identifier) (list/compose g!actor-vars)) - g!inputsC (|> (get@ #inputs signature) (list/map product.left)) - g!inputsT (|> (get@ #inputs signature) (list/map product.right)) + g!all-vars (|> (get@ #vars signature) (list;map code.local-identifier) (list;compose g!actor-vars)) + g!inputsC (|> (get@ #inputs signature) (list;map product.left)) + g!inputsT (|> (get@ #inputs signature) (list;map product.right)) g!state (|> signature (get@ #state) code.local-identifier) g!self (|> signature (get@ #self) code.local-identifier) g!actor-refs (: (List Code) (if (list.empty? actor-vars) (list) - (|> actor-vars list.size list.indices (list/map (|>> code.nat (~) ($) (`)))))) + (|> actor-vars list.size list.indices (list;map (|>> code.nat (~) ($) (`)))))) ref-replacements (|> (if (list.empty? actor-vars) (list) - (|> actor-vars list.size list.indices (list/map (|>> code.nat (~) ($) (`))))) + (|> actor-vars list.size list.indices (list;map (|>> code.nat (~) ($) (`))))) (: (List Code)) (list.zip2 g!all-vars) (: (List [Code Code]))) - g!outputT (list/fold (function (_ [g!var g!ref] outputT) + g!outputT (list;fold (function (_ [g!var g!ref] outputT) (code.replace g!var g!ref outputT)) (get@ #output signature) ref-replacements)]] diff --git a/stdlib/source/lux/control/concurrency/frp.lux b/stdlib/source/lux/control/concurrency/frp.lux index 0dae2798e..a91a4f531 100644 --- a/stdlib/source/lux/control/concurrency/frp.lux +++ b/stdlib/source/lux/control/concurrency/frp.lux @@ -9,15 +9,15 @@ ["." monad (#+ Monad do)] ["ex" exception (#+ exception:)]] [data - ["." maybe ("#/." functor)] + ["." maybe ("#;." functor)] ["." error (#+ Error)] [collection - ["." list ("#/." monoid)]]] + ["." list ("#;." monoid)]]] [type (#+ :share) abstract]] [// ["." atom (#+ Atom)] - ["." promise (#+ Promise) ("#/." functor)]]) + ["." promise (#+ Promise) ("#;." functor)]]) (type: #export (Channel a) {#.doc "An asynchronous channel to distribute values."} @@ -101,8 +101,8 @@ (structure: #export functor (Functor Channel) (def: (map f) - (promise/map - (maybe/map + (promise;map + (maybe;map (function (_ [head tail]) [(f head) (map f tail)]))))) @@ -148,7 +148,7 @@ (def: #export (from-promise promise) (All [a] (-> (Promise a) (Channel a))) - (promise/map (function (_ value) + (promise;map (function (_ value) (#.Some [value (promise.resolved #.None)])) promise)) diff --git a/stdlib/source/lux/control/concurrency/stm.lux b/stdlib/source/lux/control/concurrency/stm.lux index 8b26eb699..6d1fd0d3b 100644 --- a/stdlib/source/lux/control/concurrency/stm.lux +++ b/stdlib/source/lux/control/concurrency/stm.lux @@ -15,7 +15,7 @@ [// ["." atom (#+ Atom atom)] ["." promise (#+ Promise Resolver)] - ["." frp ("#/." functor)]]) + ["." frp ("#;." functor)]]) (type: #export (Observer a) (-> a (IO Any))) |