diff --git a/relay.go b/relay.go index 693f902..5b389bc 100644 --- a/relay.go +++ b/relay.go @@ -330,6 +330,11 @@ func newCall(mainOffer receivedSignal, r *activeRelay) { rtpBuf := make([]byte, 1400) for { + + if r.closed { + return + } + i, readErr := remoteTrack.Read(rtpBuf) if readErr != nil { // Could not read from remote track