diff options
| author | Fuwn <[email protected]> | 2021-06-06 00:24:21 +0000 |
|---|---|---|
| committer | Fuwn <[email protected]> | 2021-06-06 00:24:21 +0000 |
| commit | 7cebc1e93093c68c65ce1dfb540d2dd30a9159a0 (patch) | |
| tree | c1568d3cd8ea95aba32b1ac41debad57b1a37f30 /crates/whirl_server/src/interaction/peer.rs | |
| parent | fix(whirl_server::hub): space between debug log message (diff) | |
| download | whirl-7cebc1e93093c68c65ce1dfb540d2dd30a9159a0.tar.xz whirl-7cebc1e93093c68c65ce1dfb540d2dd30a9159a0.zip | |
refactor(whirl_server): move orphan types out of orphan module
Diffstat (limited to 'crates/whirl_server/src/interaction/peer.rs')
| -rw-r--r-- | crates/whirl_server/src/interaction/peer.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/crates/whirl_server/src/interaction/peer.rs b/crates/whirl_server/src/interaction/peer.rs index 6a04b17..d7ac49e 100644 --- a/crates/whirl_server/src/interaction/peer.rs +++ b/crates/whirl_server/src/interaction/peer.rs @@ -9,11 +9,11 @@ use tokio::{ }; use tokio_util::codec::{BytesCodec, Framed}; -use crate::{interaction::shared::Shared, types::Rx}; +use crate::interaction::shared::Shared; pub struct Peer { pub bytes: Framed<TcpStream, BytesCodec>, - pub rx: Rx, + pub rx: mpsc::UnboundedReceiver<bytes::BytesMut>, } impl Peer { pub async fn new( |