283         stream_id: &u32,  in on_amf0_command_message()
317                     let stream_id = match others.pop() {  in on_amf0_command_message()  localVariable
328                     self.on_delete_stream(transaction_id, &stream_id).await?;  in on_amf0_command_message()
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()
717         event_messages.write_stream_begin(*stream_id).await?;  in on_publish()