Start up subscriber RTCP worker in one-shot-signalling mode. (#3194)

pkg/rtc/participant.go

@@ -1892,6 +1892,8 @@ func (p *ParticipantImpl) onPublisherInitialConnected() {
 	}
 
 	if p.params.UseOneShotSignallingMode {
+		go p.subscriberRTCPWorker()
+
 		p.setDownTracksConnected()
 	}
 

pkg/rtc/transportmanager.go

@@ -265,7 +265,11 @@ func (t *TransportManager) RemoveTrackLocal(sender *webrtc.RTPSender) error {
 }
 
 func (t *TransportManager) WriteSubscriberRTCP(pkts []rtcp.Packet) error {
-	return t.subscriber.WriteRTCP(pkts)
+	if t.params.UseOneShotSignallingMode {
+		return t.publisher.WriteRTCP(pkts)
+	} else {
+		return t.subscriber.WriteRTCP(pkts)
+	}
 }
 
 func (t *TransportManager) GetSubscriberPacer() pacer.Pacer {