Searched refs:dc1 (Results 1 – 2 of 2) sorted by relevance
199 dc1.commit_reliability_params(); in pr_ordered_unordered_test()251 dc1.close().await?; in pr_ordered_unordered_test()297 let n = dc1.read(&mut rbuf[..]).await?; in test_data_channel_channel_type_reliable_ordered()305 let n = dc1.read(&mut rbuf[..]).await?; in test_data_channel_channel_type_reliable_ordered()314 dc1.close().await?; in test_data_channel_channel_type_reliable_ordered()349 dc1.commit_reliability_params(); in test_data_channel_channel_type_reliable_unordered()386 dc1.close().await?; in test_data_channel_channel_type_reliable_unordered()462 let n = dc1.read(&mut rbuf[..]).await?; in test_data_channel_buffered_amount()491 let dc1_cloned = Arc::clone(&dc1); in test_data_channel_buffered_amount()511 dc1.close().await?; in test_data_channel_buffered_amount()[all …]
286 let dc1 = Arc::clone(&dc); in test_data_channel_send_after_connected() localVariable294 assert!(dc1.ordered(), "Ordered should be set to true"); in test_data_channel_send_after_connected()296 dc1.on_message(Box::new(move |_: DataChannelMessage| { in test_data_channel_send_after_connected()304 if dc1.send_text("Ping".to_owned()).await.is_err() { in test_data_channel_send_after_connected()306 let dc2 = Arc::clone(&dc1); in test_data_channel_send_after_connected()307 dc1.on_open(Box::new(move || { in test_data_channel_send_after_connected()