38 lines
1.2 KiB
Racket
38 lines
1.2 KiB
Racket
#lang racket/base
|
|
;; A more different trivial example program demonstrating os2-tcp.rkt.
|
|
|
|
(require racket/string)
|
|
(require racket/set)
|
|
(require racket/match)
|
|
(require "os2.rkt")
|
|
(require "os2-tcp.rkt")
|
|
|
|
(define ((connection-handler local-addr remote-addr) self-pid)
|
|
(transition 'no-state
|
|
(send-tcp-mode remote-addr local-addr 'lines)
|
|
(send-tcp-credit remote-addr local-addr 1)
|
|
(role (topic-subscriber (tcp-channel remote-addr local-addr (wild)))
|
|
[(tcp-channel remote _ (? bytes? line))
|
|
(list (send-tcp-credit remote-addr local-addr 1)
|
|
(send-message
|
|
(tcp-channel local-addr remote-addr (bytes-append #"You said: " line #"\n"))))]
|
|
[(tcp-channel remote _ (? eof-object?))
|
|
(quit)])))
|
|
|
|
(define (listener local-addr)
|
|
(transition 'no-state
|
|
(role (topic-subscriber (tcp-channel (wild) local-addr (wild)) #:monitor? #t)
|
|
#:topic t
|
|
#:on-presence (match t
|
|
[(topic 'publisher (tcp-channel remote-addr (== local-addr) _) #f)
|
|
(spawn (connection-handler local-addr remote-addr))]))))
|
|
|
|
(define (main port)
|
|
(ground-vm
|
|
(transition 'none
|
|
(spawn tcp-spy)
|
|
(spawn tcp-driver)
|
|
(spawn (listener (tcp-listener port))))))
|
|
|
|
(main 5999)
|