diff --git a/internal/audio/output_streaming.go b/internal/audio/output_streaming.go index a92f961..07c13ab 100644 --- a/internal/audio/output_streaming.go +++ b/internal/audio/output_streaming.go @@ -91,4 +91,4 @@ func StopAudioOutputStreaming() { for atomic.LoadInt32(&outputStreamingRunning) == 1 { time.Sleep(10 * time.Millisecond) } -} \ No newline at end of file +} diff --git a/internal/audio/relay.go b/internal/audio/relay.go index 4082747..17d94c2 100644 --- a/internal/audio/relay.go +++ b/internal/audio/relay.go @@ -12,13 +12,13 @@ import ( // AudioRelay handles forwarding audio frames from the audio server subprocess // to WebRTC without any CGO audio processing. This runs in the main process. type AudioRelay struct { - client *AudioClient - ctx context.Context - cancel context.CancelFunc - wg sync.WaitGroup - logger *zerolog.Logger - running bool - mutex sync.RWMutex + client *AudioClient + ctx context.Context + cancel context.CancelFunc + wg sync.WaitGroup + logger *zerolog.Logger + running bool + mutex sync.RWMutex // WebRTC integration audioTrack AudioTrackWriter @@ -35,8 +35,6 @@ type AudioTrackWriter interface { WriteSample(sample media.Sample) error } - - // NewAudioRelay creates a new audio relay for the main process func NewAudioRelay() *AudioRelay { ctx, cancel := context.WithCancel(context.Background()) @@ -195,4 +193,4 @@ func (r *AudioRelay) incrementDropped() { r.mutex.Lock() r.framesDropped++ r.mutex.Unlock() -} \ No newline at end of file +} diff --git a/internal/audio/relay_api.go b/internal/audio/relay_api.go index 7e25708..6be34cd 100644 --- a/internal/audio/relay_api.go +++ b/internal/audio/relay_api.go @@ -106,4 +106,4 @@ func UpdateAudioRelayTrack(audioTrack AudioTrackWriter) error { // Update the track in the existing relay globalRelay.UpdateTrack(audioTrack) return nil -} \ No newline at end of file +}