Lines Matching refs:config
42 pub config: Config, field
53 pub fn new(stream: Arc<Stream>, config: Config) -> Self { in new()
55 config, in new()
65 config: Config, in dial()
71 Self::client(stream, config).await in dial()
77 config: Config, in accept()
99 Self::server(stream, config).await in accept()
103 pub async fn client(stream: Arc<Stream>, config: Config) -> Result<Self> { in client()
104 if !config.negotiated { in client()
106 channel_type: config.channel_type, in client()
107 priority: config.priority, in client()
108 reliability_parameter: config.reliability_parameter, in client()
109 label: config.label.bytes().collect(), in client()
110 protocol: config.protocol.bytes().collect(), in client()
118 Ok(DataChannel::new(stream, config)) in client()
122 pub async fn server(stream: Arc<Stream>, mut config: Config) -> Result<Self> { in server()
135 config.channel_type = dco.channel_type; in server()
136 config.priority = dco.priority; in server()
137 config.reliability_parameter = dco.reliability_parameter; in server()
138 config.label = String::from_utf8(dco.label)?; in server()
139 config.protocol = String::from_utf8(dco.protocol)?; in server()
144 let data_channel = DataChannel::new(stream, config); in server()
346 let (unordered, reliability_type) = match self.config.channel_type { in commit_reliability_params()
358 self.config.reliability_parameter, in commit_reliability_params()