diff --git a/pkg/rtc/transportmanager.go b/pkg/rtc/transportmanager.go index 0bb6960ae..0baf27870 100644 --- a/pkg/rtc/transportmanager.go +++ b/pkg/rtc/transportmanager.go @@ -377,6 +377,7 @@ func (t *TransportManager) createDataChannelsForSubscriber(pendingDataChannels [ return err } + ordered = false retransmits := uint16(0) negotiated = t.params.Migration && lossyIDPtr == nil if err := t.subscriber.CreateDataChannel(LossyDataChannel, &webrtc.DataChannelInit{ @@ -778,6 +779,7 @@ func (t *TransportManager) ProcessPendingPublisherDataChannels() { err error ) if ci.Label == LossyDataChannel { + ordered = false retransmits := uint16(0) id := uint16(ci.GetId()) dcLabel, dcID, dcExisting, err = t.publisher.CreateDataChannelIfEmpty(LossyDataChannel, &webrtc.DataChannelInit{ diff --git a/test/client/client.go b/test/client/client.go index 08c03e20b..f5bae8b46 100644 --- a/test/client/client.go +++ b/test/client/client.go @@ -255,6 +255,7 @@ func NewRTCClient(conn *websocket.Conn, opts *Options) (*RTCClient, error) { return nil, err } + ordered = false maxRetransmits := uint16(0) if err := c.publisher.CreateDataChannel(rtc.LossyDataChannel, &webrtc.DataChannelInit{ Ordered: &ordered,