mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-05 05:47:40 +03:00
Code Issues Projects Releases Packages Wiki Activity

Glommio clippy

Browse source
This commit is contained in:
Nikolay Kim 2024-04-07 22:47:58 +05:00
parent a858394855
commit ccafe7a8be
3 changed files with 10 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

2
ntex-bytes/Cargo.toml
View file

@ -30,4 +30,4 @@ simdutf8 = { version = "0.1.4", optional = true }
serde_test = "1" serde_test = "1"
serde_json = "1" serde_json = "1"
ntex = { version = "1", features = ["tokio"] } ntex = { version = "1", features = ["tokio"] }
ntex-bytes = { version = "*", features = ["mpool"] } ntex-bytes = { path = ".", features = ["mpool"] }

14
ntex-glommio/src/io.rs
View file

@ -203,9 +203,10 @@ impl Future for WriteTask {
Poll::Ready(Ok(())) => { Poll::Ready(Ok(())) => {
let io = this.io.clone(); let io = this.io.clone();
let fut = Box::pin(async move { let fut = Box::pin(async move {
io.0.borrow() let fut =
.shutdown(std::net::Shutdown::Write) io.0.borrow()
.await .shutdown(std::net::Shutdown::Write);
fut.await
}); });
*st = Shutdown::Close(fut); *st = Shutdown::Close(fut);
continue; continue;
@ -511,9 +512,10 @@ impl Future for UnixWriteTask {
Poll::Ready(Ok(())) => { Poll::Ready(Ok(())) => {
let io = this.io.clone(); let io = this.io.clone();
let fut = Box::pin(async move { let fut = Box::pin(async move {
io.0.borrow() let fut =
.shutdown(std::net::Shutdown::Write) io.0.borrow()
.await .shutdown(std::net::Shutdown::Write);
fut.await
}); });
*st = Shutdown::Close(fut); *st = Shutdown::Close(fut);
continue; continue;

2
ntex-glommio/src/signals.rs
View file

@ -1,7 +1,7 @@
use std::{cell::RefCell, future::Future, pin::Pin, rc::Rc, task::Context, task::Poll}; use std::{cell::RefCell, future::Future, pin::Pin, rc::Rc, task::Context, task::Poll};
thread_local! { thread_local! {
static SRUN: RefCell<bool> = RefCell::new(false); static SRUN: RefCell<bool> = const { RefCell::new(false) };
static SHANDLERS: Rc<RefCell<Vec<oneshot::Sender<Signal>>>> = Default::default(); static SHANDLERS: Rc<RefCell<Vec<oneshot::Sender<Signal>>>> = Default::default();
} }