Method SubscribeObserve

internal/sessions/manager.go:352–362

SubscribeObserve creates a channel that receives observe events for a session.

(sessionID, subID string)

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

// UnsubscribeObserve removes an observer and closes its channel.
func (m *Manager) UnsubscribeObserve(sessionID, subID string) {