72 lines
1.9 KiB
Racket
72 lines
1.9 KiB
Racket
#lang minimart
|
|
|
|
(require (only-in racket/port read-line-evt))
|
|
(require "../drivers/timer.rkt")
|
|
|
|
(define (quasi-spy e s)
|
|
(printf "----------------------------------------\n")
|
|
(printf "QUASI-SPY:\n")
|
|
(match e
|
|
[(routing-update g) (pretty-print-gestalt g)]
|
|
[other
|
|
(write other)
|
|
(newline)])
|
|
(printf "========================================\n")
|
|
#f)
|
|
(spawn quasi-spy (void) (gestalt-union (sub ? #:level 10 #:meta-level 1)
|
|
(pub ? #:level 10 #:meta-level 1)
|
|
(sub ? #:level 10)
|
|
(pub ? #:level 10)))
|
|
|
|
(define (r e s)
|
|
(match e
|
|
[(message body _ _) (transition s (send `(print got ,body) #:meta-level 1))]
|
|
[_ #f]))
|
|
|
|
(define (b e n)
|
|
(match e
|
|
[#f (if (< n 10)
|
|
(transition (+ n 1) (send `(hello ,n)))
|
|
#f)]
|
|
[_ #f]))
|
|
|
|
(spawn-world (spawn r (void) (sub ?))
|
|
(spawn b 0))
|
|
|
|
(define (echoer e s)
|
|
(match e
|
|
[(message (event _ (list (? eof-object?))) _ _) (transition s (quit))]
|
|
[(message (event _ (list line)) _ _) (transition s (send `(print got-line ,line)))]
|
|
[_ #f]))
|
|
|
|
(spawn echoer (void) (sub (event (read-line-evt (current-input-port) 'any) ?)
|
|
#:meta-level 1))
|
|
|
|
(define (ticker e s)
|
|
(match e
|
|
[(routing-update g)
|
|
(printf "EMPTY? ~v\n" (gestalt-empty? g))
|
|
(printf "INTERSECTED:\n")
|
|
(pretty-print-gestalt (gestalt-filter g (pub (set-timer ? ? ?) #:level 1)))
|
|
#f]
|
|
[(message (timer-expired 'tick now) _ _)
|
|
(printf "TICK ~v\n" now)
|
|
(transition (+ s 1) (if (< s 3)
|
|
(send (set-timer 'tick 1000 'relative))
|
|
(quit)))]
|
|
[_ #f]))
|
|
|
|
(spawn-timer-driver)
|
|
(send (set-timer 'tick 1000 'relative))
|
|
(spawn ticker 1 (gestalt-union (pub (set-timer ? ? ?) #:level 1)
|
|
(sub (timer-expired 'tick ?))))
|
|
|
|
(define (printer e s)
|
|
(match e
|
|
[(message (cons 'print v) _ _)
|
|
(log-info "PRINTER: ~a" v)
|
|
#f]
|
|
[_ #f]))
|
|
|
|
(spawn printer (void) (sub `(print . ,?)))
|