180         if let Some(rtsp_request) = RtspRequest::unmarshal(std::str::from_utf8(&data)?) {  in on_rtsp_message()
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()
189                     self.handle_announce(&rtsp_request).await?;  in on_rtsp_message()
192                     self.handle_setup(&rtsp_request).await?;  in on_rtsp_message()
195                     if self.handle_play(&rtsp_request).await.is_err() {  in on_rtsp_message()
196                         self.unsubscribe_from_stream_hub(rtsp_request.path)?;  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()
217     async fn handle_options(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> {  in handle_options()
219         let mut response = Self::gen_response(status_code, rtsp_request);  in handle_options()
227     async fn handle_describe(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> {  in handle_describe()
236                 stream_path: rtsp_request.path.clone(),  in handle_describe()
255         let mut response = Self::gen_response(status_code, rtsp_request);  in handle_describe()
267     async fn handle_announce(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> {  in handle_announce()
268         if let Some(request_body) = &rtsp_request.body {  in handle_announce()
282                 stream_path: rtsp_request.path.clone(),  in handle_announce()
320         let response = Self::gen_response(status_code, rtsp_request);  in handle_announce()
326     async fn handle_setup(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> {  in handle_setup()
328         let mut response = Self::gen_response(status_code, rtsp_request);  in handle_setup()
331             if !rtsp_request.url.contains(&track.media_control) {  in handle_setup()
335             if let Some(transport_data) = rtsp_request.get_header(&"Transport".to_string()) {  in handle_setup()
359                             let address = rtsp_request.address.clone();  in handle_setup()
413     async fn handle_play(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> {  in handle_play()
460         let response = Self::gen_response(status_code, rtsp_request);  in handle_play()
468                 stream_path: rtsp_request.path.clone(),  in handle_play()
544     async fn handle_record(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> {  in handle_record()
545         if let Some(range_str) = rtsp_request.headers.get(&String::from("Range")) {  in handle_record()
548                 let mut response = Self::gen_response(status_code, rtsp_request);  in handle_record()
563     fn handle_teardown(&mut self, rtsp_request: &RtspRequest) -> Result<(), SessionError> {  in handle_teardown()
564         let stream_path = &rtsp_request.path;  in handle_teardown()
638     fn gen_response(status_code: StatusCode, rtsp_request: &RtspRequest) -> RtspResponse {  in gen_response()
652         if let Some(cseq) = rtsp_request.headers.get("CSeq") {  in gen_response()