update processor

livekit · Oct 2, 2024 · 866518e · 866518e
1 parent aa3c2d6
commit 866518e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 10 deletions.
diff --git a/pkg/media/processor.go b/pkg/media/processor.go
@@ -14,9 +14,6 @@
 
 package media
 
-type Processor[T any] interface {
-	SetWriter(writer WriteCloser[T])
-	WriteCloser[T]
-}
+type Processor[T any] func(w WriteCloser[T]) WriteCloser[T]
 
 type PCM16Processor = Processor[PCM16Sample]
diff --git a/pkg/sip/media_port.go b/pkg/sip/media_port.go
@@ -209,15 +209,11 @@ func (p *MediaPort) setupOutput() {
 	// TODO: this says "audio", but actually includes DTMF too
 	s := rtp.NewSeqWriter(newRTPStatsWriter(p.mon, "audio", p.conn))
 	p.audioOutRTP = s.NewStream(p.conf.AudioType, p.conf.Audio.Info().RTPClockRate)
+
 	// Encoding pipeline (LK -> SIP)
 	audioOut := p.conf.Audio.EncodeRTP(p.audioOutRTP)
-
 	if processor := p.conf.Processor; processor != nil {
-		if audioOut.SampleRate() != processor.SampleRate() {
-			audioOut = media.ResampleWriter(audioOut, processor.SampleRate())
-		}
-		processor.SetWriter(audioOut)
-		audioOut = processor
+		audioOut = processor(audioOut)
 	}
 
 	if p.conf.DTMFType != 0 {