syndicate-lang
/
minimart-2014
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Tweaks to userland examples

This commit is contained in:
Tony Garnock-Jones 2014-06-02 16:46:54 -04:00
parent a572f270f0
commit 95f050aca6
2 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
minimart/examples/chat-userland.rkt
View File

@ -15,15 +15,15 @@
(define (say who fmt . vs)
(unless (equal? who user) (send-to-remote "~a ~a\n" who (apply format fmt vs))))
(define remote-detector (pub #:meta-level 1 #:level 1 (tcp-channel us them ?)))
(define tcp-gestalt (gestalt-union (pub (tcp-channel us them ?) #:meta-level 1 #:level 1)
(pub (tcp-channel us them ?) #:meta-level 1)
(sub (tcp-channel them us ?) #:meta-level 1)))
(userland-thread #:gestalt (gestalt-union (sub `(,? says ,?))
(userland-thread #:gestalt (gestalt-union tcp-gestalt
(sub `(,? says ,?))
(sub `(,? says ,?) #:level 1)
(pub `(,user says ,?))
(sub (tcp-channel them us ?) #:meta-level 1)
(pub (tcp-channel us them ?) #:meta-level 1)
remote-detector)
(wait-for-gestalt remote-detector)
(pub `(,user says ,?)))
(wait-for-gestalt tcp-gestalt)
(send-to-remote "Welcome, ~a.\n" user)
(let loop ((old-peers (set)))
(match (next-event)
@ -34,10 +34,9 @@
(say who "says: ~a" what)
(loop old-peers)]
[(routing-update g)
(define remote-present? (not (gestalt-empty? (gestalt-filter g remote-detector))))
(when (gestalt-empty? (gestalt-filter g tcp-gestalt)) (do (quit)))
(define new-peers (matcher-key-set/single
(gestalt-project g 0 0 #t (compile-gestalt-projection `(,(?!) says ,?)))))
(when (not remote-present?) (do (quit)))
(for/list [(who (set-subtract new-peers old-peers))] (say who "arrived."))
(for/list [(who (set-subtract old-peers new-peers))] (say who "departed."))
(loop new-peers)]))))

6
minimart/examples/chat-userland2.rkt
View File

@ -20,8 +20,9 @@
(userland-thread #:gestalt tcp-gestalt
(wait-for-gestalt tcp-gestalt)
(send-to-remote "Welcome. What is your name? > ")
(send-to-remote "What is your name? > ")
(define user (read-chunk))
(send-to-remote "Welcome, ~a.\n" user)
(do (routing-update (gestalt-union tcp-gestalt
(sub `(,? says ,?) #:level 1)
@ -41,10 +42,9 @@
(say who "says: ~a" what)
(loop old-peers)]
[(routing-update g)
(define remote-present? (not (gestalt-empty? (gestalt-filter g tcp-gestalt))))
(when (gestalt-empty? (gestalt-filter g tcp-gestalt)) (do (quit)))
(define new-peers (matcher-key-set/single
(gestalt-project g 0 0 #t (compile-gestalt-projection `(,(?!) says ,?)))))
(when (not remote-present?) (do (quit)))
(for/list [(who (set-subtract new-peers old-peers))] (say who "arrived."))
(for/list [(who (set-subtract old-peers new-peers))] (say who "departed."))
(loop new-peers)]))))