summaryrefslogtreecommitdiff
path: root/ext/flash/socket.rs
diff options
context:
space:
mode:
Diffstat (limited to 'ext/flash/socket.rs')
-rw-r--r--ext/flash/socket.rs18
1 files changed, 7 insertions, 11 deletions
diff --git a/ext/flash/socket.rs b/ext/flash/socket.rs
index 7c75b230a..8256be8a0 100644
--- a/ext/flash/socket.rs
+++ b/ext/flash/socket.rs
@@ -1,26 +1,23 @@
use deno_core::error::AnyError;
use mio::net::TcpStream;
-use std::cell::UnsafeCell;
-use std::future::Future;
-use std::io::Read;
-use std::io::Write;
-use std::marker::PhantomPinned;
-use std::pin::Pin;
-use std::sync::Arc;
-use std::sync::Mutex;
+use std::{
+ cell::UnsafeCell,
+ future::Future,
+ io::{Read, Write},
+ pin::Pin,
+ sync::{Arc, Mutex},
+};
use tokio::sync::mpsc;
use crate::ParseStatus;
type TlsTcpStream = rustls::StreamOwned<rustls::ServerConnection, TcpStream>;
-#[derive(Debug)]
pub enum InnerStream {
Tcp(TcpStream),
Tls(Box<TlsTcpStream>),
}
-#[derive(Debug)]
pub struct Stream {
pub inner: InnerStream,
pub detached: bool,
@@ -29,7 +26,6 @@ pub struct Stream {
pub parse_done: ParseStatus,
pub buffer: UnsafeCell<Vec<u8>>,
pub read_lock: Arc<Mutex<()>>,
- pub _pinned: PhantomPinned,
}
impl Stream {