Method closeFromHub

internal/nodehub/stream.go:77–87

closeFromHub 由 hub 内部触发的终结（node 回了终态帧 / 连接断开），不发 cancel。

(endErr error)

// closeFromHub 由 hub 内部触发的终结（node 回了终态帧 / 连接断开），不发 cancel。
func (s *Stream) closeFromHub(endErr error) {
	s.closeOnce.Do(func() {
		s.conn.streamSubs.Delete(s.reqID)
		s.mu.Lock()
		s.err = endErr
		s.closed = true
		s.mu.Unlock()
		close(s.done)
		close(s.frames)
	})
}

// deliver 把一帧投递到 frames 通道。投递在 mu 保护下检查 closed，避免向已关闭通道写入。
// frames 缓冲不足时阻塞等待消费方，但若同时 Close 触发则立即放弃（done 兜底）。