Method Unsubscribe

internal/sessions/manager.go:317–328

Unsubscribe removes a subscriber and closes its channel.

(sessionID, subID string)

// Unsubscribe removes a subscriber and closes its channel.
func (m *Manager) Unsubscribe(sessionID, subID string) {
	sess := m.Get(sessionID)
	if sess == nil {
		return
	}
	sess.mu.Lock()
	defer sess.mu.Unlock()
	if ch, ok := sess.subscribers[subID]; ok {
		close(ch)
		delete(sess.subscribers, subID)
	}
}

// PublishResult sends a result to all subscribers of a session.
func (m *Manager) PublishResult(sessionID string, result *CommandResult) {