diff options
Diffstat (limited to 'ext/flash/socket.rs')
-rw-r--r-- | ext/flash/socket.rs | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/ext/flash/socket.rs b/ext/flash/socket.rs index 8256be8a0..7c75b230a 100644 --- a/ext/flash/socket.rs +++ b/ext/flash/socket.rs @@ -1,23 +1,26 @@ use deno_core::error::AnyError; use mio::net::TcpStream; -use std::{ - cell::UnsafeCell, - future::Future, - io::{Read, Write}, - pin::Pin, - sync::{Arc, Mutex}, -}; +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 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, @@ -26,6 +29,7 @@ pub struct Stream { pub parse_done: ParseStatus, pub buffer: UnsafeCell<Vec<u8>>, pub read_lock: Arc<Mutex<()>>, + pub _pinned: PhantomPinned, } impl Stream { |