10     association::Association, chunk::chunk_payload_data::PayloadProtocolIdentifier, stream::*,
43     stream: Arc<Stream>,  field
53     pub fn new(stream: Arc<Stream>, config: Config) -> Self {  in new()
56             stream,  in new()
67         let stream = association  in dial()  localVariable
71         Self::client(stream, config).await  in dial()
83         let stream = association  in accept()  localVariable
89             if channel.stream_identifier() == stream.stream_identifier() {  in accept()
91                 ch.stream  in accept()
97         stream.set_default_payload_type(PayloadProtocolIdentifier::Binary);  in accept()
99         Self::server(stream, config).await  in accept()
103     pub async fn client(stream: Arc<Stream>, config: Config) -> Result<Self> {  in client()
114             stream  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()
125         let (n, ppi) = stream.read_sctp(&mut buf).await?;  in server()
144         let data_channel = DataChannel::new(stream, config);  in server()
166             let (mut n, ppi) = match self.stream.read_sctp(buf).await {  in read_data_channel()
233         self.stream.stream_identifier()  in stream_identifier()
283                 .stream  in write_data_channel()
288             let n = self.stream.write_sctp(data, ppi).await?;  in write_data_channel()
300             .stream  in write_data_channel_ack()
318         Ok(self.stream.shutdown(Shutdown::Both).await?)  in close()
324         self.stream.buffered_amount()  in buffered_amount()
330         self.stream.buffered_amount_low_threshold()  in buffered_amount_low_threshold()
336         self.stream.set_buffered_amount_low_threshold(threshold)  in set_buffered_amount_low_threshold()
342         self.stream.on_buffered_amount_low(f)  in on_buffered_amount_low()
355         self.stream.set_reliability_params(  in commit_reliability_params()
641                         .stream  in poll_shutdown()