Function untilConnectionState

peerconnection_test.go:142–160

(state PeerConnectionState, peers ...*PeerConnection)

}

func untilConnectionState(state PeerConnectionState, peers ...*PeerConnection) *sync.WaitGroup {
	var triggered sync.WaitGroup
	triggered.Add(len(peers))

	for _, p := range peers {
		var done atomic.Value
		done.Store(false)
		hdlr := func(p PeerConnectionState) {
			if val, ok := done.Load().(bool); ok && (!val && p == state) {
				done.Store(true)
				triggered.Done()
			}
		}

		p.OnConnectionStateChange(hdlr)
	}

	return &triggered
}

func TestNew(t *testing.T) {
	pc, err := NewPeerConnection(Configuration{