diff --git a/test/scenario/network/network_emulation_pc_unittest.cc b/test/scenario/network/network_emulation_pc_unittest.cc index 105cb56bbd..f2fcb07da4 100644 --- a/test/scenario/network/network_emulation_pc_unittest.cc +++ b/test/scenario/network/network_emulation_pc_unittest.cc @@ -159,8 +159,11 @@ TEST(NetworkEmulationManagerPCTest, Run) { network_manager.Start(); signaling_thread->Invoke(RTC_FROM_HERE, [&]() { - rtc::scoped_refptr channel = - alice->CreateDataChannel("data"); + rtc::scoped_refptr source = + alice_pcf->CreateAudioSource(cricket::AudioOptions()); + rtc::scoped_refptr track = + alice_pcf->CreateAudioTrack("audio", source); + alice->AddTransceiver(track); // Connect peers. ASSERT_TRUE(alice->ExchangeOfferAnswerWith(bob.get())); @@ -180,13 +183,6 @@ TEST(NetworkEmulationManagerPCTest, Run) { ASSERT_TRUE_WAIT(bob->IsIceConnected(), kDefaultTimeoutMs); ASSERT_TRUE_WAIT(alice->IsIceConnected(), kDefaultTimeoutMs); - ASSERT_TRUE_WAIT(bob->observer()->last_datachannel_ != nullptr, - kDefaultTimeoutMs); - MockDataChannelObserver observer(bob->observer()->last_datachannel_); - channel->Send(DataBuffer("Test data")); - ASSERT_TRUE_WAIT(observer.received_message_count() == 1, kDefaultTimeoutMs); - ASSERT_EQ("Test data", observer.last_message()); - // Close peer connections alice->pc()->Close(); bob->pc()->Close();