Function callStreamAdapter

internal/nodehub/register.go:18–28

callStreamAdapter 把 nodes.HubStreamFunc 适配到 *Hub.CallStream。 hub any 必须是 *Hub 类型；其他类型将返回错误。

(ctx context.Context, hub any, nodeID, method string, body any)

// callStreamAdapter 把 nodes.HubStreamFunc 适配到 *Hub.CallStream。
// hub any 必须是 *Hub 类型；其他类型将返回错误。
func callStreamAdapter(ctx context.Context, hub any, nodeID, method string, body any) (nodes.HubStream, error) {
h, ok := hub.(*Hub)
if !ok {
return nil, ErrNodeOffline
}
s, err := h.CallStream(ctx, nodeID, method, body)
if err != nil {
return nil, err
}
return &nodesStreamAdapter{s: s, frames: convertFrames(s)}, nil
}

// nodesStreamAdapter 把 *Stream 包成 nodes.HubStream（重新打包 frames 通道
// 以适配 nodes 包定义的 HubStreamFrame 类型）。