Lines Matching refs:stream_id
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()
500 pub fn on_stream_is_recorded(&mut self, stream_id: &mut u32) -> Result<(), SessionError> { in on_stream_is_recorded()
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()
506 log::trace!("stream is begin stream_id is {}", stream_id); in on_stream_begin()