Method notifySessionReady

internal/bridge/bridge.go:299–303

notifySessionReady signals any goroutines waiting for the given session.

(sessionID string)

// notifySessionReady signals any goroutines waiting for the given session.
func (b *Bridge) notifySessionReady(sessionID string) {
	if ch, loaded := b.sessionReady.LoadAndDelete(sessionID); loaded {
		close(ch.(chan struct{}))
	}
}

// reconnectSpiteStream attempts to re-open the SpiteStream with exponential backoff.
func (b *Bridge) reconnectSpiteStream(lastErr error) {