32 lines
1.1 KiB
Racket
32 lines
1.1 KiB
Racket
#lang syndicate/core
|
|
|
|
(require syndicate/protocol/advertise)
|
|
(require/activate "../drivers/websocket.rkt")
|
|
(require "../demand-matcher.rkt")
|
|
|
|
(define any-client any-websocket-remote-client)
|
|
(define server-id (websocket-local-server 8081 #f))
|
|
|
|
(define (spawn-connection-handler c)
|
|
(log-info "spawn-connection-handler ~v" c)
|
|
(define (connection-handler e n)
|
|
(when e (log-info "connection-handler ~v: ~v /// ~v" c e n))
|
|
(match e
|
|
[(? patch/removed?) (quit)]
|
|
[_
|
|
(if (< n 20)
|
|
(transition (+ n 1) (message (websocket-message server-id c (format "msg ~v" n))))
|
|
#f)]))
|
|
(actor connection-handler
|
|
0
|
|
(patch-seq (sub (advertise (websocket-message c server-id ?)))
|
|
(sub (websocket-message c server-id ?))
|
|
(pub (websocket-message server-id c ?)))))
|
|
|
|
(spawn-demand-matcher (advertise (websocket-message (?! any-client) server-id ?))
|
|
(observe (websocket-message (?! any-client) server-id ?))
|
|
spawn-connection-handler
|
|
(lambda (c)
|
|
(log-info "Connection handler ~v decided to exit" c)
|
|
'()))
|