Rename UtpSocket to UtpStream

ethereum · May 26, 2022 · 64f9cf4 · 64f9cf4
1 parent 0dbc155
commit 64f9cf4
Show file tree

Hide file tree

Showing 3 changed files with 115 additions and 115 deletions.
diff --git a/trin-core/src/portalnet/overlay.rs b/trin-core/src/portalnet/overlay.rs
@@ -18,7 +18,7 @@ use crate::portalnet::{
 use crate::{
     portalnet::types::content_key::RawContentKey,
     utp::{
-        stream::{UtpListenerRequest, UtpSocket, BUF_SIZE},
+        stream::{UtpListenerRequest, UtpStream, BUF_SIZE},
         trin_helpers::{UtpAccept, UtpMessage, UtpStreamId},
     },
 };
@@ -281,7 +281,7 @@ impl<TContentKey: OverlayContentKey + Send, TMetric: Metric + Send>
         conn_id: u16,
     ) -> Result<Content, OverlayRequestError> {
         // initiate the connection to the acceptor
-        let (tx, rx) = tokio::sync::oneshot::channel::<anyhow::Result<UtpSocket>>();
+        let (tx, rx) = tokio::sync::oneshot::channel::<anyhow::Result<UtpStream>>();
         self.utp_listener_tx
             .send(UtpListenerRequest::Connect(
                 conn_id,
@@ -390,7 +390,7 @@ impl<TContentKey: OverlayContentKey + Send, TMetric: Metric + Send>
         }
 
         // initiate the connection to the acceptor
-        let (tx, rx) = tokio::sync::oneshot::channel::<anyhow::Result<UtpSocket>>();
+        let (tx, rx) = tokio::sync::oneshot::channel::<anyhow::Result<UtpStream>>();
 
         self.utp_listener_tx.send(UtpListenerRequest::Connect(
             conn_id,