Searched refs:rtsp_request (Results 1 – 2 of 2) sorted by relevance
181 match rtsp_request.method.as_str() { in on_rtsp_message()183 self.handle_options(&rtsp_request).await?; in on_rtsp_message()186 self.handle_describe(&rtsp_request).await?; in on_rtsp_message()192 self.handle_setup(&rtsp_request).await?; in on_rtsp_message()200 self.handle_record(&rtsp_request).await?; in on_rtsp_message()203 self.handle_teardown(&rtsp_request)?; in on_rtsp_message()236 stream_path: rtsp_request.path.clone(), in handle_describe()268 if let Some(request_body) = &rtsp_request.body { in handle_announce()282 stream_path: rtsp_request.path.clone(), in handle_announce()468 stream_path: rtsp_request.path.clone(), in handle_play()[all …]
27 let mut rtsp_request = RtspRequest::default(); in unmarshal() localVariable35 rtsp_request.method = method.to_string(); in unmarshal()38 rtsp_request.url = url.to_string(); in unmarshal()43 rtsp_request.path = String::from(path); in unmarshal()50 rtsp_request.address = address; in unmarshal()53 rtsp_request.port = port; in unmarshal()61 rtsp_request.version = version.to_string(); in unmarshal()69 rtsp_request.headers.insert(name, value); in unmarshal()79 rtsp_request.body = Some(request_data[header_end_idx..].to_string()); in unmarshal()82 Some(rtsp_request) in unmarshal()