syndicate-lang
/
syndicate-rkt
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Sensible defaults; and return local source/sink from establish-connection

This commit is contained in:
Tony Garnock-Jones 2021-06-18 17:43:16 +02:00
parent 20eeb6cd55
commit 2e0b9505cc
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
syndicate/drivers/stream.rkt
View File

@ -309,11 +309,11 @@
(when initial-credit (send-credit (peer-source) initial-credit initial-mode))
(on-connect (peer-source) (peer-sink))]
[(_ 'disconnected)
(on-disconnect)]
((or on-disconnect (lambda () (stop-current-facet))))]
[('pending (list 'error m))
(on-rejected m)]
((or on-rejected (lambda (m) (stop-current-facet))) m)]
[(_ (list 'error m))
(on-error m)])))
((or on-error (lambda (m) (stop-current-facet))) m)])))
(define-field peer-source #f)
(define-field peer-sink #f)
@ -332,7 +332,8 @@
#:on-error (lambda (m) (transition (list 'error m)))
#:on-data on-data
#:on-eof on-eof))
(at ds (assert (StreamConnection source sink spec))))
(at ds (assert (StreamConnection source sink spec)))
(list source sink))
;;---------------------------------------------------------------------------