From 5e2279f9530277d9eab30935ef15e1d7a754cd38 Mon Sep 17 00:00:00 2001
From: Justin Franco <justin.franco@smartcontract.com>
Date: Fri, 9 Jan 2026 17:47:17 -0700
Subject: [PATCH] Adds callback on stream reconnects

---
 go/stream.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/go/stream.go b/go/stream.go
index 9f38f13..acd1ec5 100644
--- a/go/stream.go
+++ b/go/stream.go
@@ -256,6 +256,9 @@ func (s *stream) monitorConn(conn *wsConn) {
 			return
 		}
 		conn.replace(re.conn)
+		if s.connStatusCallback != nil {
+			go s.connStatusCallback(true, conn.host, conn.origin)
+		}
 		s.config.logInfo(
 			"client: stream websocket %s: reconnected",
 			conn.origin,