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)