131                 let data = self.io.lock().await.read().await?;  in run()  localVariable
132                 self.reader.extend_from_slice(&data[..]);  in run()
135             if let Ok(data) = InterleavedBinaryData::new(&mut self.reader) {  in run()
136                 match data {  in run()
139                             let data = self.io.lock().await.read().await?;  in run()  localVariable
140                             self.reader.extend_from_slice(&data[..]);  in run()
178         let data = self.reader.extract_remaining_bytes();  in on_rtsp_message()  localVariable
180         if let Some(rtsp_request) = RtspRequest::unmarshal(std::str::from_utf8(&data)?) {  in on_rtsp_message()
247         if let Some(Information::Sdp { data }) = receiver.recv().await {  in handle_describe()
248             if let Some(sdp) = Sdp::unmarshal(&data) {  in handle_describe()
488                         mut data,  in handle_play()
495                                 .on_frame(&mut data, timestamp)  in handle_play()
501                         mut data,  in handle_play()
508                                 .on_frame(&mut data, timestamp)  in handle_play()
748                             Fmtp::H264(data) => {  in send_prior_data()
750                                 bytes_writer.write(&data.sps)?;  in send_prior_data()
752                                 bytes_writer.write(&data.pps)?;  in send_prior_data()
756                                     data: bytes_writer.extract_current_bytes(),  in send_prior_data()
763                             Fmtp::H265(data) => {  in send_prior_data()
765                                 bytes_writer.write(&data.sps)?;  in send_prior_data()
767                                 bytes_writer.write(&data.pps)?;  in send_prior_data()
769                                 bytes_writer.write(&data.vps)?;  in send_prior_data()
773                                     data: bytes_writer.extract_current_bytes(),  in send_prior_data()
781                             Fmtp::Mpeg4(data) => {  in send_prior_data()
784                                     data: data.asc.clone(),  in send_prior_data()
820             data: self.sdp.lock().await.marshal(),  in send_information()