diff --git a/pkg/node/transport.go b/pkg/node/transport.go index 19dbf7d..9d0f538 100644 --- a/pkg/node/transport.go +++ b/pkg/node/transport.go @@ -52,7 +52,7 @@ func DefaultTransportConfig() TransportConfig { } } -// MessageHandler processes incoming messages. +// transport.OnMessage(func(conn *PeerConnection, msg *Message) { worker.HandleMessage(conn, msg) }) type MessageHandler func(conn *PeerConnection, msg *Message) // MessageDeduplicator tracks seen message IDs to prevent duplicate processing