| /xiu/library/streamhub/src/notify/ |
| H A D | mod.rs | 25 pub async fn on_publish_notify(&self, body: String) { in on_publish_notify()
30 .body(body) in on_publish_notify()
44 pub async fn on_unpublish_notify(&self, body: String) { in on_unpublish_notify()
49 .body(body) in on_unpublish_notify()
63 pub async fn on_play_notify(&self, body: String) { in on_play_notify()
68 .body(body) in on_play_notify()
82 pub async fn on_stop_notify(&self, body: String) { in on_stop_notify()
87 .body(body) in on_stop_notify()
|
| /xiu/application/http-server/src/ |
| H A D | main.rs | 33 async fn on_publish(body: String) { in on_publish()
34 log::info!("on_publish body: {}", body); in on_publish()
37 async fn on_unpublish(body: String) { in on_unpublish()
38 log::info!("on_unpublish body: {}", body); in on_unpublish()
41 async fn on_play(body: String) { in on_play()
42 log::info!("on_play body: {}", body); in on_play()
45 async fn on_stop(body: String) { in on_stop()
46 log::info!("on_stop body: {}", body); in on_stop()
|
| /xiu/protocol/rtsp/src/http/ |
| H A D | mod.rs | 16 pub body: Option<String>, field
79 rtsp_request.body = Some(request_data[header_end_idx..].to_string()); in unmarshal()
94 if let Some(body) = &self.body { in marshal()
95 request_str += &format!("Content-Length: {}\r\n", body.len()); in marshal()
98 if let Some(body) = &self.body { in marshal()
99 request_str += body; in marshal()
111 pub body: Option<String>, field
169 if let Some(body) = &self.body { in marshal()
170 response_str += &format!("Content-Length: {}\r\n", body.len()); in marshal()
173 if let Some(body) = &self.body { in marshal()
[all …]
|
| /xiu/protocol/rtmp/src/cache/ |
| H A D | metadata.rs | 27 pub fn save(&mut self, body: &BytesMut) { in save()
28 if self.is_metadata(body.clone()) { in save()
29 self.chunk_body = body.clone(); in save()
43 pub fn is_metadata(&mut self, body: BytesMut) -> bool { in is_metadata()
44 let reader = BytesReader::new(body); in is_metadata()
|
| /xiu/protocol/webrtc/src/http/ |
| H A D | mod.rs | 32 pub body: Option<String>, field
120 http_request.body = Some(request_data[header_end_idx..].to_string()); in unmarshal()
137 if let Some(body) = &self.body { in marshal()
138 request_str += &format!("Content-Length: {}\r\n", body.len()); in marshal()
146 if let Some(body) = &self.body { in marshal()
147 request_str += body; in marshal()
159 pub body: Option<String>, field
219 if let Some(body) = &self.body { in marshal()
220 response_str += &format!("Content-Length: {}\r\n", body.len()); in marshal()
224 if let Some(body) = &self.body { in marshal()
[all …]
|
| /xiu/library/container/flv/src/ |
| H A D | muxer.rs | 58 pub fn write_flv_tag_body(&mut self, body: BytesMut) -> Result<(), FlvMuxerError> { in write_flv_tag_body()
59 self.writer.write(&body[..])?; in write_flv_tag_body()
|
| H A D | demuxer.rs | 247 let body = self.bytes_reader.read_bytes(data_size as usize)?; in read_flv_tag() localVariable
253 data: body, in read_flv_tag()
259 data: body, in read_flv_tag()
|
| /xiu/protocol/hls/src/ |
| H A D | server.rs | 56 .body(NOTFOUND.into()) in not_found()
65 let body = Body::wrap_stream(stream); in simple_file_send() localVariable
66 return Ok(Response::new(body)); in simple_file_send()
|
| /xiu/protocol/webrtc/src/clients/ |
| H A D | whep.js | 78 body: offer.sdp, property
165 body: JSON.stringify(events), property
349 body: fragment, property
388 body: JSON.stringify(muted), property
409 body: JSON.stringify(layer), property
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 141 let sdp_data = if let Some(body) = http_request.body.as_ref() { in run()
142 body in run()
284 response.body = Some(session_description.sdp); in publish_whip()
398 response.body = Some(session_description.sdp); in subscribe_whep()
497 response.body = Some(contents_str); in gen_file_response()
|
| /xiu/protocol/httpflv/src/ |
| H A D | server.rs | 58 .body(NOTFOUND.into()) in handle_connection()
|
| /xiu/protocol/rtmp/src/chunk/ |
| H A D | unpacketizer.rs | 660 let mut body = BytesMut::new(); in test_set_chunk_size() localVariable
661 body.extend_from_slice(&[00, 00, 10, 00]); in test_set_chunk_size()
663 let expected = ChunkInfo::new(2, 0, 0, 4, 1, 0, body); in test_set_chunk_size()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 258 response.body = Some(sdp); in handle_describe()
268 if let Some(request_body) = &rtsp_request.body { in handle_announce()
|
| /xiu/ |
| H A D | Cargo.lock | 249 "http-body",
280 "http-body",
1328 name = "http-body"
1403 "http-body",
2186 "http-body",
2962 "http-body",
|