From dfd51a5235cc1ef9b04cd81e7d38aad8f6951464 Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Fri, 18 Jun 2021 18:12:23 +0200 Subject: [PATCH] Repair connection-state tracking --- syndicate/drivers/stream.rkt | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/syndicate/drivers/stream.rkt b/syndicate/drivers/stream.rkt index 4a6df55..5f2f6af 100644 --- a/syndicate/drivers/stream.rkt +++ b/syndicate/drivers/stream.rkt @@ -301,7 +301,6 @@ #:on-data on-data #:on-eof [on-eof void]) (define connection-state 'pending) - (begin/dataflow (log-info "connection-state ~a" connection-state)) (define (transition new-state) (when (not (equal? connection-state new-state)) (match* (connection-state new-state) @@ -313,7 +312,8 @@ [('pending (list 'error m)) ((or on-rejected (lambda (m) (stop-current-facet))) m)] [(_ (list 'error m)) - ((or on-error (lambda (m) (stop-current-facet))) m)]))) + ((or on-error (lambda (m) (stop-current-facet))) m)]) + (set! connection-state new-state))) (define-field peer-source #f) (define-field peer-sink #f)