actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2024-11-24 00:01:11 +01:00
Code Issues Releases Wiki Activity

clippy run on -tls

Browse Source
This commit is contained in:
Rob Ede 2023-04-01 05:24:00 +01:00
parent c60d2f9ddb
commit c6ebbcf21b
No known key found for this signature in database
GPG Key ID: 97C636207D3EF933
5 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
actix-server/src/test_server.rs
View File

@ -117,7 +117,7 @@ impl TestServerHandle {
/// Stop server. /// Stop server.
fn stop(&mut self) { fn stop(&mut self) {
let _ = self.server_handle.stop(false); drop(self.server_handle.stop(false));
self.thread_handle.take().unwrap().join().unwrap().unwrap(); self.thread_handle.take().unwrap().join().unwrap().unwrap();
} }

2
actix-server/tests/server.rs
View File

@ -1,3 +1,5 @@
#![allow(clippy::let_underscore_future)]
use std::{ use std::{
net, net,
sync::{ sync::{

6
actix-tls/src/accept/native_tls.rs
View File

@ -73,17 +73,17 @@ impl<IO: ActixStream> AsyncWrite for TlsStream<IO> {
} }
fn is_write_vectored(&self) -> bool { fn is_write_vectored(&self) -> bool {
(&**self).is_write_vectored() (**self).is_write_vectored()
} }
} }
impl<IO: ActixStream> ActixStream for TlsStream<IO> { impl<IO: ActixStream> ActixStream for TlsStream<IO> {
fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> { fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> {
IO::poll_read_ready((&**self).get_ref().get_ref().get_ref(), cx) IO::poll_read_ready((**self).get_ref().get_ref().get_ref(), 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>> {
IO::poll_write_ready((&**self).get_ref().get_ref().get_ref(), cx) IO::poll_write_ready((**self).get_ref().get_ref().get_ref(), cx)
} }
} }

6
actix-tls/src/accept/openssl.rs
View File

@ -76,17 +76,17 @@ impl<IO: ActixStream> AsyncWrite for TlsStream<IO> {
} }
fn is_write_vectored(&self) -> bool { fn is_write_vectored(&self) -> bool {
(&**self).is_write_vectored() (**self).is_write_vectored()
} }
} }
impl<IO: ActixStream> ActixStream for TlsStream<IO> { impl<IO: ActixStream> ActixStream for TlsStream<IO> {
fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> { fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> {
IO::poll_read_ready((&**self).get_ref(), cx) IO::poll_read_ready((**self).get_ref(), 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>> {
IO::poll_write_ready((&**self).get_ref(), cx) IO::poll_write_ready((**self).get_ref(), cx)
} }
} }

6
actix-tls/src/accept/rustls.rs
View File

@ -76,17 +76,17 @@ impl<IO: ActixStream> AsyncWrite for TlsStream<IO> {
} }
fn is_write_vectored(&self) -> bool { fn is_write_vectored(&self) -> bool {
(&**self).is_write_vectored() (**self).is_write_vectored()
} }
} }
impl<IO: ActixStream> ActixStream for TlsStream<IO> { impl<IO: ActixStream> ActixStream for TlsStream<IO> {
fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> { fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<io::Result<Ready>> {
IO::poll_read_ready((&**self).get_ref().0, cx) IO::poll_read_ready((**self).get_ref().0, 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>> {
IO::poll_write_ready((&**self).get_ref().0, cx) IO::poll_write_ready((**self).get_ref().0, cx)
} }
} }