Searched refs:open_stream (Results 1 – 6 of 6) sorted by relevance
74 let stream = a.open_stream(0, PayloadProtocolIdentifier::String).await?; in main()
120 .open_stream(0, PayloadProtocolIdentifier::Binary) in main()
575 pub async fn open_stream( in open_stream() method581 ai.open_stream(stream_identifier, default_payload_type) in open_stream()
189 .open_stream(si, PayloadProtocolIdentifier::Binary) in establish_session_pair()2319 let s11 = a1.open_stream(1, PayloadProtocolIdentifier::String).await?; in test_association_shutdown()2320 let s21 = a2.open_stream(1, PayloadProtocolIdentifier::String).await?; in test_association_shutdown()2378 let s11 = a1.open_stream(1, PayloadProtocolIdentifier::String).await?; in test_association_shutdown_during_write()2379 let s21 = a2.open_stream(1, PayloadProtocolIdentifier::String).await?; in test_association_shutdown_during_write()
1017 pub(crate) fn open_stream( in open_stream() method
68 .open_stream(identifier, PayloadProtocolIdentifier::Binary) in dial()