diff --git a/broadcast-latency-prospect.rkt b/broadcast-latency-prospect.rkt index 388b266..57a8d8c 100644 --- a/broadcast-latency-prospect.rkt +++ b/broadcast-latency-prospect.rkt @@ -53,9 +53,9 @@ '()))] [_ #f])) #f - (sub (pong ?)) - (sub 'kickoff) - (pub (ping src dst ?)))) + (patch-seq (sub (pong ?)) + (sub 'kickoff) + (pub (ping src dst ?))))) (define (echoer id) (spawn (lambda (e s) @@ -64,8 +64,8 @@ (transition s (message (pong stamp)))] [_ #f])) #f - (sub (ping ? ? ?)) - (pub (pong ?)))) + (patch-seq (sub (ping ? ? ?)) + (pub (pong ?))))) (begin (run-ground (for/list [(id (in-range echoer-count))] (echoer id)) diff --git a/echo-server-prospect-tcp-driver.rkt b/echo-server-prospect-tcp-driver.rkt index 1fb85a4..c6c8d57 100644 --- a/echo-server-prospect-tcp-driver.rkt +++ b/echo-server-prospect-tcp-driver.rkt @@ -70,9 +70,9 @@ (transition s (message (tcp-channel dst src bs)))] [_ #f])) #f - (sub (advertise (tcp-channel c server-id ?))) - (sub (tcp-channel c server-id ?)) - (pub (tcp-channel server-id c ?)))) + (patch-seq (sub (advertise (tcp-channel c server-id ?))) + (sub (tcp-channel c server-id ?)) + (pub (tcp-channel server-id c ?))))) (run-ground (spawn-timer-driver) (spawn-tcp-driver) diff --git a/internal-latency-prospect.rkt b/internal-latency-prospect.rkt index b769654..4ea32b3 100644 --- a/internal-latency-prospect.rkt +++ b/internal-latency-prospect.rkt @@ -49,9 +49,9 @@ '()))] [_ #f])) #f - (sub (ping dst src ?)) - (sub 'kickoff) - (pub (ping src dst ?)))) + (patch-seq (sub (ping dst src ?)) + (sub 'kickoff) + (pub (ping src dst ?))))) (define (echoer id) (spawn (lambda (e s) @@ -60,8 +60,8 @@ (transition s (message (ping id src stamp)))] [_ #f])) #f - (sub (ping ? id ?)) - (pub (ping id ? ?)))) + (patch-seq (sub (ping ? id ?)) + (pub (ping id ? ?))))) (begin (run-ground (for/list [(id (in-range echoer-count))] (echoer id)) diff --git a/observe-all-prospect.rkt b/observe-all-prospect.rkt index 71280eb..ddf5310 100644 --- a/observe-all-prospect.rkt +++ b/observe-all-prospect.rkt @@ -23,8 +23,8 @@ (transition (+ count 1) '())] [_ #f])) 0 - (pub (presence id)) - (sub (advertise (presence ?))))) + (patch-seq (pub (presence id)) + (sub (advertise (presence ?)))))) (define boot-actions (for/list [(id (in-range peer-count))] (peer id))) (define-values (results cpu-time wall-clock-time gc-time) diff --git a/observe-some-prospect.rkt b/observe-some-prospect.rkt index c17da03..1581896 100644 --- a/observe-some-prospect.rkt +++ b/observe-some-prospect.rkt @@ -22,9 +22,9 @@ (transition (+ count 1) '())] [_ #f])) 0 - (assert (client)) - ;; (assert (observe (server ?))) - )) + (patch-seq (assert (client)) + ;; (assert (observe (server ?))) + ))) (define (spawn-server id) (spawn (lambda (e count) @@ -34,8 +34,8 @@ (transition (+ count 1) '())] [_ #f])) 0 - ;; (assert (server id)) - (assert (observe (client))))) + (patch-seq ;; (assert (server id)) + (assert (observe (client)))))) (define client-action (spawn-client)) (define server-actions (for/list [(id (in-range (- peer-count 1)))] (spawn-server id))) diff --git a/sum-all-prospect.rkt b/sum-all-prospect.rkt index 49c558f..1551cba 100644 --- a/sum-all-prospect.rkt +++ b/sum-all-prospect.rkt @@ -32,8 +32,8 @@ (transition count '()))] [_ #f])) 0 - (pub (presence id)) - (sub (advertise (presence ?))))) + (patch-seq (pub (presence id)) + (sub (advertise (presence ?)))))) (define start-time (current-inexact-milliseconds)) (run-ground (for/list [(id (in-range peer-count))] (peer id)))