Lines Matching refs:transaction_id
239 transaction_id, in process_messages()
244 self.on_amf0_command_message(command_name, transaction_id, command_object, others) in process_messages()
284 transaction_id: &Amf0ValueType, in on_amf0_command_message()
295 let transaction_id = match transaction_id { in on_amf0_command_message() localVariable
308 "_result" => match transaction_id { in on_amf0_command_message()
339 pub async fn send_connect(&mut self, transaction_id: &f64) -> Result<(), SessionError> { in send_connect()
371 .write_connect(transaction_id, &properties) in send_connect()
377 pub async fn send_create_stream(&mut self, transaction_id: &f64) -> Result<(), SessionError> { in send_create_stream()
379 netconnection.write_create_stream(transaction_id).await?; in send_create_stream()
386 transaction_id: &f64, in send_delete_stream()
391 .write_delete_stream(transaction_id, stream_id) in send_delete_stream()
399 transaction_id: &f64, in send_publish()
405 .write_publish(transaction_id, stream_name, stream_type) in send_publish()
413 transaction_id: &f64, in send_play()
421 .write_play(transaction_id, stream_name, start, duration, reset) in send_play()
426 .write_get_stream_length(transaction_id, stream_name) in send_play()