Home
last modified time | relevance | path

Searched refs:transaction_id (Results 1 – 7 of 7) sorted by relevance

/xiu/protocol/rtmp/src/netstream/
H A Dwriter.rs44 transaction_id: &f64, in write_play()
62 transaction_id: &f64, in write_delete_stream()
76 transaction_id: &f64, in write_close_stream()
90 transaction_id: &f64, in write_release_stream()
104 transaction_id: &f64, in write_fcpublish()
118 transaction_id: &f64, in write_receive_audio()
132 transaction_id: &f64, in write_receive_video()
145 transaction_id: &f64, in write_publish()
169 transaction_id: &f64, in write_pause()
185 transaction_id: &f64, in write_on_bw_done()
[all …]
/xiu/protocol/rtmp/src/netconnection/
H A Dwriter.rs95 transaction_id: &f64, in write_connect_with_value()
99 self.amf0_writer.write_number(transaction_id)?; in write_connect_with_value()
107 transaction_id: &f64, in write_connect()
111 self.amf0_writer.write_number(transaction_id)?; in write_connect()
187 transaction_id: &f64, in write_connect_response()
196 self.amf0_writer.write_number(transaction_id)?; in write_connect_response()
237 transaction_id: &f64, in write_create_stream()
241 self.amf0_writer.write_number(transaction_id)?; in write_create_stream()
249 transaction_id: &f64, in write_create_stream_response()
262 transaction_id: &f64, in write_get_stream_length()
[all …]
/xiu/protocol/rtmp/src/session/
H A Dserver_session.rs250 transaction_id, in process_messages()
295 let transaction_id = match transaction_id { in on_amf0_command_message() localVariable
424 transaction_id: &f64, in on_connect()
464 transaction_id, in on_connect()
493 transaction_id: &f64, in on_delete_stream()
507 transaction_id, in on_delete_stream()
536 transaction_id: &f64, in on_play()
608 transaction_id, in on_play()
617 transaction_id, in on_play()
626 transaction_id, in on_play()
[all …]
H A Dclient_session.rs239 transaction_id, 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()
371 .write_connect(transaction_id, &properties) in send_connect()
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()
413 transaction_id: &f64, in send_play()
[all …]
/xiu/protocol/rtmp/src/amf0/
H A Damf0_reader.rs210 let transaction_id = amf_reader.read_with_type(amf0_markers::NUMBER).unwrap(); in test_amf_reader() localVariable
211 assert_eq!(transaction_id, Amf0ValueType::Number(1.0)); in test_amf_reader()
338 let transaction_id = amf_reader.read_with_type(amf0_markers::NUMBER).unwrap(); in test_player_connect_reader() localVariable
339 assert_eq!(transaction_id, Amf0ValueType::Number(1.0)); in test_player_connect_reader()
/xiu/protocol/rtmp/src/messages/
H A Dparser.rs35 let transaction_id = amf_reader.read_with_type(amf0_markers::NUMBER)?; in parse() localVariable
55 transaction_id, in parse()
H A Ddefine.rs20 transaction_id: Amf0ValueType,