fix issue

ckousik · Dec 6, 2022 · 8709645 · 8709645
1 parent 626947f
commit 8709645
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/p2p/transport/webrtc/datachannel.go b/p2p/transport/webrtc/datachannel.go
@@ -109,7 +109,7 @@ func newDataChannel(
 }
 
 func (d *dataChannel) Read(b []byte) (int, error) {
-
+	d.startReadLoop()
 	timeout := make(chan struct{})
 	var deadlineTimer *time.Timer
 	first := true
@@ -166,6 +166,7 @@ func (d *dataChannel) Write(b []byte) (int, error) {
 	// Check if there is any message on the wire. This is used for control
 	// messages only
 	if state == stateReadClosed {
+		d.startReadLoop()
 		// drain the channel
 		select {
 		case <-d.receivedMessage: