@@ -18,7 +18,7 @@ use crate::portalnet::{
18
18
use crate :: {
19
19
portalnet:: types:: content_key:: RawContentKey ,
20
20
utp:: {
21
- stream:: { UtpListenerRequest , UtpSocket , BUF_SIZE } ,
21
+ stream:: { UtpListenerRequest , UtpStream , BUF_SIZE } ,
22
22
trin_helpers:: { UtpAccept , UtpMessage , UtpStreamId } ,
23
23
} ,
24
24
} ;
@@ -281,7 +281,7 @@ impl<TContentKey: OverlayContentKey + Send, TMetric: Metric + Send>
281
281
conn_id : u16 ,
282
282
) -> Result < Content , OverlayRequestError > {
283
283
// initiate the connection to the acceptor
284
- let ( tx, rx) = tokio:: sync:: oneshot:: channel :: < anyhow:: Result < UtpSocket > > ( ) ;
284
+ let ( tx, rx) = tokio:: sync:: oneshot:: channel :: < anyhow:: Result < UtpStream > > ( ) ;
285
285
self . utp_listener_tx
286
286
. send ( UtpListenerRequest :: Connect (
287
287
conn_id,
@@ -390,7 +390,7 @@ impl<TContentKey: OverlayContentKey + Send, TMetric: Metric + Send>
390
390
}
391
391
392
392
// initiate the connection to the acceptor
393
- let ( tx, rx) = tokio:: sync:: oneshot:: channel :: < anyhow:: Result < UtpSocket > > ( ) ;
393
+ let ( tx, rx) = tokio:: sync:: oneshot:: channel :: < anyhow:: Result < UtpStream > > ( ) ;
394
394
395
395
self . utp_listener_tx . send ( UtpListenerRequest :: Connect (
396
396
conn_id,
0 commit comments