aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--stdlib/source/lux/concurrency/space.lux154
-rw-r--r--stdlib/test/test/lux/concurrency/space.lux23
-rw-r--r--stdlib/test/tests.lux2
3 files changed, 0 insertions, 179 deletions
diff --git a/stdlib/source/lux/concurrency/space.lux b/stdlib/source/lux/concurrency/space.lux
deleted file mode 100644
index fb7f199f8..000000000
--- a/stdlib/source/lux/concurrency/space.lux
+++ /dev/null
@@ -1,154 +0,0 @@
-(.module:
- lux
- (lux (control [monad #+ do]
- ["ex" exception #+ exception:]
- ["p" parser])
- (concurrency ["P" promise]
- ["T" task]
- ["A" actor #+ actor:])
- (data [product]
- (coll [list "L/" Functor<List> Fold<List>]))
- [io #- run]
- [macro #+ with-gensyms]
- (macro [code]
- ["s" syntax #+ syntax:]
- (syntax ["cs" common]
- (common ["csr" reader]
- ["csw" writer])))))
-
-(with-expansions
- [<Event> [e (A.Actor Top) (Space e)]
- <Action> (as-is (-> <Event> (A.Actor s) (T.Task Bool)))]
- (type: #export (Space e)
- (A.Actor (List (Ex [s] [(A.Actor s) <Action>]))))
-
- (type: #export (Event e)
- <Event>)
-
- (type: #export (Action e)
- (All [s] <Action>)))
-
-(exception: #export Closed-Space)
-
-(def: (send-space message space)
- (All [s] (-> (A.Message s) (A.Actor s) (T.Task Unit)))
- (P.future (do Monad<IO>
- [success? (A.send message space)]
- (wrap (if success?
- (ex.return [])
- (ex.throw Closed-Space ""))))))
-
-(def: #export (subscribe actor action space)
- (All [e s] (-> (A.Actor s) (Action e s) (Space e) (T.Task Unit)))
- (send-space (function [subscriptions _]
- (T.return (|> subscriptions
- (list.filter (|>> product.left (:! []) (is (:! [] actor)) not))
- (#.Cons [actor action]))))
- space))
-
-(def: #export (un-subscribe actor space)
- (All [e s] (-> (A.Actor s) (Space e) (T.Task Unit)))
- (send-space (function [subscriptions _]
- (T.return (|> subscriptions
- (list.filter (|>> product.left (:! []) (is (:! [] actor)) not)))))
- space))
-
-(def: #export (emit event space sender)
- (All [e s] (-> e (Space e) (A.Actor s) (T.Task Unit)))
- (send-space (function [subscriptions _]
- (exec (do T.Monad<Task>
- [verdicts (monad.map @
- (function [(^@ sub [receiver action])]
- (if (is (:! [] receiver) (:! [] sender))
- (T.return [true sub])
- (do @
- [sent? (action [event sender space] receiver)]
- (wrap [sent? sub]))))
- subscriptions)]
- (T.return (L/fold (function [[sent? sub] survivors]
- (if sent?
- (#.Cons sub survivors)
- survivors))
- (list)
- verdicts)))))
- space))
-
-(def: #export space
- (All [e] (IO (Space e)))
- (A.spawn A.default-behavior (list)))
-
-(type: ActionS
- {#action-name Text
- #sender-name Text
- #space-name Text
- #event Code
- #state Code
- #receiver-name Text})
-
-(def: reference^
- (s.Syntax [Ident (List Code)])
- (p.either (s.form (p.seq s.symbol (p.some s.any)))
- (p.seq s.symbol (:: p.Monad<Parser> wrap (list)))))
-
-(def: action^
- (s.Syntax ActionS)
- (s.form ($_ p.seq
- s.local-symbol
- s.local-symbol
- s.local-symbol
- s.any
- s.any
- s.local-symbol)))
-
-(def: type-vars^
- (s.Syntax (List Text))
- (p.either (s.tuple (p.some s.local-symbol))
- (:: p.Monad<Parser> wrap (list))))
-
-(syntax: #export (on: [export csr.export]
- [t-vars type-vars^]
- [[actor-name actor-params] reference^]
- eventT
- [declaration action^]
- [annotations (p.default cs.empty-annotations csr.annotations)]
- body)
- {#.doc (doc (type: Move
- #Ping
- #Pong)
-
- (actor: #export Player {}
- {#hits Nat})
-
- (on: #export Move (counter move space hits self)
- (do @
- [_ (emit (case move
- #.Ping #.Pong
- #.Pong #.Ping)
- space
- self)]
- (wrap (n/inc hits)))))}
- (with-gensyms [g!_]
- (do @
- [actor-name (A.resolve-actor actor-name)
- #let [stateT (` ((~ (code.symbol (product.both id A.state-name actor-name)))
- (~+ actor-params)))
- g!actionL (code.local-symbol (get@ #action-name declaration))
- g!senderL (code.local-symbol (get@ #sender-name declaration))
- g!spaceL (code.local-symbol (get@ #space-name declaration))
- g!receiverL (code.local-symbol (get@ #receiver-name declaration))
- g!event (get@ #event declaration)
- g!state (get@ #state declaration)]]
- (wrap (list (` (def: (~+ (csw.export export)) ((~ g!actionL) [(~ g!event) (~ g!senderL) (~ g!spaceL)] (~ g!receiverL))
- (~ (csw.annotations annotations))
- (All [(~+ (L/map code.local-symbol t-vars))]
- (..Action (~ eventT) (~ stateT)))
- (T.from-promise
- ((~! P.future)
- (A.send (function [(~ g!state) (~ g!receiverL)]
- (: (T.Task (~ stateT))
- (monad.do T.Monad<Task>
- []
- (~ body))))
- (~ g!receiverL))))
- ))))
- )))
diff --git a/stdlib/test/test/lux/concurrency/space.lux b/stdlib/test/test/lux/concurrency/space.lux
deleted file mode 100644
index dd295501e..000000000
--- a/stdlib/test/test/lux/concurrency/space.lux
+++ /dev/null
@@ -1,23 +0,0 @@
-(.module:
- lux
- (lux (control [monad #+ do])
- (concurrency ["T" task]
- ["A" actor #+ actor:]
- ["S" space #+ on:])
- [io]))
-
-(type: Move
- #Ping
- #Pong)
-
-(A.actor: #export Player {}
- {#hits Nat})
-
-(on: Player Move (reply! who where what state self)
- (do @
- [_ (S.emit (case what
- #Ping #Pong
- #Pong #Ping)
- where
- self)]
- (wrap (update@ #hits n/inc state))))
diff --git a/stdlib/test/tests.lux b/stdlib/test/tests.lux
index 9a0fedbb8..899582b54 100644
--- a/stdlib/test/tests.lux
+++ b/stdlib/test/tests.lux
@@ -10,7 +10,6 @@
["_." duration]
["_." date])
(concurrency ["_." actor]
- ["_." space]
["_." atom]
["_." frp]
["_." promise]
@@ -75,7 +74,6 @@
))
(lux (control [contract]
[concatenative])
- (concurrency [space])
(data [env]
[trace]
[store]