Searched refs:stream_id (Results 1 – 9 of 9) sorted by relevance
| /xiu/protocol/rtmp/src/user_control_messages/ |
| H A D | writer.rs | 33 pub async fn write_stream_begin(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_begin()
37 self.writer.write_u32::<BigEndian>(stream_id)?; in write_stream_begin()
43 pub async fn write_stream_eof(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_eof()
47 self.writer.write_u32::<BigEndian>(stream_id)?; in write_stream_eof()
54 pub async fn write_stream_dry(&mut self, stream_id: u32) -> Result<(), EventMessagesError> { in write_stream_dry()
58 self.writer.write_u32::<BigEndian>(stream_id)?; in write_stream_dry()
67 stream_id: u32, in write_set_buffer_length()
73 self.writer.write_u32::<BigEndian>(stream_id)?; in write_set_buffer_length()
83 stream_id: u32, in write_stream_is_record()
88 self.writer.write_u32::<BigEndian>(stream_id)?; in write_stream_is_record()
|
| H A D | reader.rs | 44 let stream_id = self.reader.read_u32::<BigEndian>()?; in read_set_buffer_length() localVariable
48 stream_id, in read_set_buffer_length()
56 let stream_id = self.reader.read_u32::<BigEndian>()?; in read_stream_begin() localVariable
59 stream_id, in read_stream_begin()
66 let stream_id = self.reader.read_u32::<BigEndian>()?; in read_stream_is_recorded() localVariable
69 stream_id, in read_stream_is_recorded()
|
| /xiu/protocol/rtmp/src/messages/ |
| H A D | define.rs | 50 stream_id: u32,
54 stream_id: u32,
57 stream_id: u32,
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | client_session.rs | 258 RtmpMessageData::StreamBegin { stream_id } => { in process_messages()
260 self.on_stream_begin(stream_id)?; in process_messages()
262 RtmpMessageData::StreamIsRecorded { stream_id } => { in process_messages()
264 self.on_stream_is_recorded(stream_id)?; in process_messages()
387 stream_id: &f64, in send_delete_stream()
391 .write_delete_stream(transaction_id, stream_id) in send_delete_stream()
455 stream_id: u32, in send_set_buffer_length()
459 eventmessages.write_set_buffer_length(stream_id, ms).await?; in send_set_buffer_length()
501 log::trace!("stream is recorded stream_id is {}", stream_id); in on_stream_is_recorded()
505 pub fn on_stream_begin(&mut self, stream_id: &mut u32) -> Result<(), SessionError> { in on_stream_begin()
[all …]
|
| H A D | server_session.rs | 283 stream_id: &u32, in on_amf0_command_message()
317 let stream_id = match others.pop() { in on_amf0_command_message() localVariable
339 self.on_play(transaction_id, stream_id, others).await?; in on_amf0_command_message()
343 self.on_publish(transaction_id, stream_id, others).await?; in on_amf0_command_message()
494 stream_id: &f64, in on_delete_stream()
520 log::trace!("{}", stream_id); in on_delete_stream()
537 stream_id: &u32, in on_play()
588 event_messages.write_stream_begin(*stream_id).await?; in on_play()
633 event_messages.write_stream_is_record(*stream_id).await?; in on_play()
666 stream_id: &u32, in on_publish()
[all …]
|
| /xiu/library/container/mpegts/src/ |
| H A D | pes.rs | 12 pub stream_id: u8, field
38 stream_id: 0, in new()
93 self.bytes_writer.write_u8(stream_data.stream_id)?; //3 in write_pes_header()
|
| H A D | ts.rs | 86 == (cur_stream.stream_id & define::epes_stream_id::PES_SID_VIDEO) in write()
385 cur_stream.stream_id = epes_stream_id::PES_SID_VIDEO; in pmt_add_stream()
387 cur_stream.stream_id = epes_stream_id::PES_SID_AUDIO; in pmt_add_stream()
389 cur_stream.stream_id = epes_stream_id::PES_SID_PRIVATE_1; in pmt_add_stream()
|
| /xiu/protocol/rtmp/src/netstream/ |
| H A D | writer.rs | 63 stream_id: &f64, in write_delete_stream()
69 self.amf0_writer.write_number(stream_id)?; in write_delete_stream()
77 stream_id: &f64, in write_close_stream()
83 self.amf0_writer.write_number(stream_id)?; in write_close_stream()
|
| /xiu/protocol/rtmp/src/netconnection/ |
| H A D | writer.rs | 250 stream_id: &f64, in write_create_stream_response()
255 self.amf0_writer.write_number(stream_id)?; in write_create_stream_response()
|