Method close

internal/nodehub/hub.go:377–388

()

}

func (c *conn) close() {
	c.closeOnce.Do(func() {
		close(c.closed)
	})
	// 关闭所有未结束的流订阅，避免 caller 永久阻塞。
	// 放在 closeOnce 之外是为了允许 close() 多次调用都执行（虽然实际通常只一次）。
	c.streamSubs.Range(func(key, value any) bool {
		s := value.(*Stream)
		s.closeFromHub(ErrNodeOffline)
		return true
	})
}

// IsOnline 返回指定 nodeID 是否当前在线。
func (h *Hub) IsOnline(nodeID string) bool {