|
989 | 989 | fine_audio_buffer_.reset(new FineAudioBuffer(audio_device_buffer_.get())); |
990 | 990 |
|
991 | 991 | if (!(this->observer_ != nullptr && |
992 | | - this->observer_->OnEngineWillConnectOutput( |
993 | | - engine_manual_input_, engine_manual_input_.mainMixerNode, this->OutputNode(), |
994 | | - manual_render_rtc_format_))) { |
995 | | - // Default implementation. |
996 | | - [engine_manual_input_ connect:engine_manual_input_.mainMixerNode |
997 | | - to:this->OutputNode() |
998 | | - format:manual_render_rtc_format_]; |
| 992 | + this->observer_->OnEngineWillConnectInput(engine_manual_input_, nil, |
| 993 | + engine_manual_input_.mainMixerNode, |
| 994 | + manual_render_rtc_format_))) { |
| 995 | + // No default implementation since device is not used. |
999 | 996 | } |
1000 | 997 |
|
| 998 | + [engine_manual_input_ connect:engine_manual_input_.mainMixerNode |
| 999 | + to:this->OutputNode() |
| 1000 | + format:manual_render_rtc_format_]; |
| 1001 | + |
1001 | 1002 | } else if (state.prev.IsInputEnabled() && !state.next.IsInputEnabled()) { |
1002 | 1003 | LOGI() << "Disabling input for AVAudioEngine..."; |
1003 | 1004 | RTC_DCHECK(!engine_manual_input_.running); |
|
1060 | 1061 | render_thread_ = rtc::Thread::Create(); |
1061 | 1062 | render_thread_->SetName("render_thread", nullptr); |
1062 | 1063 | render_thread_->Start(); |
1063 | | - render_thread_->PostTask([this] { |
1064 | | - // RTC_DCHECK_RUN_ON(thread_); |
1065 | | - this->StartRenderLoop(); |
1066 | | - }); |
| 1064 | + render_thread_->PostTask([this] { this->StartRenderLoop(); }); |
1067 | 1065 | } |
1068 | 1066 |
|
1069 | 1067 | if (state.prev.IsAnyEnabled() && !state.next.IsAnyEnabled()) { |
|
0 commit comments