Lines Matching refs:data
65 data = receiver.recv() => { in receive_frame_data_loop()
66 if let Some(val) = data { in receive_frame_data_loop()
70 data: _, in receive_frame_data_loop()
72 FrameData::Audio { timestamp, data } => { in receive_frame_data_loop()
73 let data = FrameData::Audio { in receive_frame_data_loop() localVariable
75 data: data.clone(), in receive_frame_data_loop()
79 … if let Err(audio_err) = v.send(data.clone()).map_err(|_| ChannelError { in receive_frame_data_loop()
86 FrameData::Video { timestamp, data } => { in receive_frame_data_loop()
87 let data = FrameData::Video { in receive_frame_data_loop() localVariable
89 data: data.clone(), in receive_frame_data_loop()
92 … if let Err(video_err) = v.send(data.clone()).map_err(|_| ChannelError { in receive_frame_data_loop()
119 data = receiver.recv() => { in receive_packet_data_loop()
120 if let Some(val) = data { in receive_packet_data_loop()
123 PacketData::Audio { timestamp, data } => { in receive_packet_data_loop()
124 let data = PacketData::Audio { in receive_packet_data_loop() localVariable
126 data: data.clone(), in receive_packet_data_loop()
130 … if let Err(audio_err) = v.send(data.clone()).map_err(|_| ChannelError { in receive_packet_data_loop()
137 PacketData::Video { timestamp, data } => { in receive_packet_data_loop()
138 let data = PacketData::Video { in receive_packet_data_loop() localVariable
140 data: data.clone(), in receive_packet_data_loop()
143 … if let Err(video_err) = v.send(data.clone()).map_err(|_| ChannelError { in receive_packet_data_loop()
330 let event_serialize_str = if let Ok(data) = serde_json::to_string(&message) { in event_loop()
331 log::info!("event data: {}", data); in event_loop()
332 data in event_loop()