(define (main . args)
(let* ((hive (make-hive))
- (sleeper (bootstrap-actor hive <sleeper>))
+ ;; (sleeper (bootstrap-actor hive <sleeper>))
(server (bootstrap-actor
hive <websocket-server>
#:port %server-port
- #:on-ws-connection
- (lambda (ws)
- (format (current-error-port) "on-ws-connection: ws=~s\n" ws)
- (when #f
- (set! (.on-close ws)
- (lambda (ws)
- (format (current-error-port) "on-close: ~s\n" ws)))
- (set! (.on-error ws)
- (lambda (ws e)
- (format (current-error-port) "on-error: ~s, ~s\n" ws e)))
- (set! (.on-message ws)
- (lambda (ws msg)
- (format (current-error-port) "on-message: ~s\n" msg)))
- (set! (.on-open ws)
- (lambda (ws)
- (format (current-error-port) "on-open: ~s\n" ws)))))
+ #:on-ws-connection (lambda (ws)
+ (format (current-error-port) "on-ws-connection: ws=~s\n" ws))
#:on-ws-close (lambda (ws)
(format (current-error-port) "on-close: ~s\n" ws))
#:on-ws-error (lambda (ws e)
#:on-ws-message (lambda (ws msg)
(format (current-error-port) "on-message: ~s: ~s\n" ws msg))
#:on-ws-open (lambda (ws)
- (format (current-error-port) "on-open: ~s\n" ws)))))
+ (format (current-error-port) "on-open: ~s\n" ws)
+ (format (current-error-port) "sending: AAA...\n")
+ (<- (actor-id ws) 'send (make-string (* 1024 1024) #\A))
+ (format (current-error-port) "sending: BBB...\n")
+ (<- (actor-id ws) 'send (make-string (* 1024 1024) #\B))))))
(format (current-error-port) "listening: ~s\n" %server-port)
(run-hive hive '())))