berkus
/
actix-net
mirror of https://github.com/fafhrd91/actix-net
1
0
Fork 0
Code Issues Releases Wiki Activity

remove override

This commit is contained in:
fakeshadow 2021-03-22 00:23:49 +08:00
parent 3e1ebed56f
commit f8f534ac34
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
actix-rt/src/lib.rs
View File

@ -73,12 +73,13 @@ pub mod net {
//! TCP/UDP/Unix bindings (mostly Tokio re-exports). //! TCP/UDP/Unix bindings (mostly Tokio re-exports).
use std::{ use std::{
future::Future,
io, io,
task::{Context, Poll}, task::{Context, Poll},
}; };
pub use tokio::io::Ready; pub use tokio::io::Ready;
use tokio::io::{AsyncRead, AsyncWrite}; use tokio::io::{AsyncRead, AsyncWrite, Interest};
pub use tokio::net::UdpSocket; pub use tokio::net::UdpSocket;
pub use tokio::net::{TcpListener, TcpSocket, TcpStream}; pub use tokio::net::{TcpListener, TcpSocket, TcpStream};
@ -100,22 +101,30 @@ pub mod net {
impl ActixStream for TcpStream { impl ActixStream for TcpStream {
fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> { fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> {
TcpStream::poll_ready(self, cx) let ready = self.ready(Interest::READABLE);
tokio::pin!(ready);
ready.poll(cx)
} }
fn poll_write_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> { fn poll_write_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> {
TcpStream::poll_ready(self, cx) let ready = self.ready(Interest::WRITABLE);
tokio::pin!(ready);
ready.poll(cx)
} }
} }
#[cfg(unix)] #[cfg(unix)]
impl ActixStream for UnixStream { impl ActixStream for UnixStream {
fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> { fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> {
UnixStream::poll_ready(self, cx) let ready = self.ready(Interest::READABLE);
self::pin!(ready);
ready.poll(cx)
} }
fn poll_write_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> { fn poll_write_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> {
UnixStream::poll_ready(self, cx) let ready = self.ready(Interest::WRITABLE);
self::pin!(ready);
ready.poll(cx)
} }
} }
} }