Method Subscribe

internal/sessions/manager.go:304–314

Subscribe creates a channel that receives command results for a session.

(sessionID, subID string)

// Subscribe creates a channel that receives command results for a session.
func (m *Manager) Subscribe(sessionID, subID string) <-chan *CommandResult {
	sess := m.Get(sessionID)
	if sess == nil {
		return nil
	}
	ch := make(chan *CommandResult, subscriberChannelSize)
	sess.mu.Lock()
	defer sess.mu.Unlock()
	sess.subscribers[subID] = ch
	return ch
}

// Unsubscribe removes a subscriber and closes its channel.
func (m *Manager) Unsubscribe(sessionID, subID string) {