refactor: create specific adapter for parent namespaces

socket/parent-broadcast-adapter.go

@@ -0,0 +1,45 @@
+package socket
+
+import (
+	"github.com/zishang520/engine.io/v2/types"
+	"github.com/zishang520/socket.io-go-parser/v2/parser"
+)
+
+type (
+	// A dummy adapter that only supports broadcasting to child (concrete) namespaces.
+	parentBroadcastAdapter struct {
+		Adapter
+
+		children *types.Set[*Namespace]
+	}
+)
+
+func MakeParentBroadcastAdapter(children *types.Set[*Namespace]) Adapter {
+	s := &parentBroadcastAdapter{
+		Adapter: MakeAdapter(),
+
+		children: children,
+	}
+
+	s.Prototype(s)
+
+	return s
+}
+
+func NewParentBroadcastAdapter(nsp NamespaceInterface, children *types.Set[*Namespace]) Adapter {
+	s := MakeParentBroadcastAdapter(children)
+
+	s.Construct(nsp)
+
+	return s
+}
+
+func (s *parentBroadcastAdapter) Construct(nsp NamespaceInterface) {
+	s.Adapter.Construct(nsp)
+}
+
+func (s *parentBroadcastAdapter) Broadcast(packet *parser.Packet, opts *BroadcastOptions) {
+	for _, nsp := range s.children.Keys() {
+		nsp.Adapter().Broadcast(packet, opts)
+	}
+}

socket/parent-namespace.go

@@ -7,7 +7,6 @@ import (
 
 	"github.com/zishang520/engine.io/v2/log"
 	"github.com/zishang520/engine.io/v2/types"
-	"github.com/zishang520/socket.io-go-parser/v2/parser"
 )
 
 var (
@@ -55,11 +54,7 @@ func NewParentNamespace(server *Server) *ParentNamespace {
 }
 
 func (p *ParentNamespace) InitAdapter() {
-	p.adapter = BroadcastAdapter(func(packet *parser.Packet, opts *BroadcastOptions) {
-		for _, nsp := range p.children.Keys() {
-			nsp.Adapter().Broadcast(packet, opts)
-		}
-	})
+	p.adapter = NewParentBroadcastAdapter(p, p.children)
 }
 
 func (p *ParentNamespace) Emit(ev string, args ...any) error {