kossLAN/wry
1
0
Fork 0
forked from wry/wry
Code Pull requests Activity

it: fix clippy lints

Browse source
This commit is contained in:
Julian Orth 2024-04-03 14:47:46 +02:00
parent 15a1b600f3
commit 6baa7ab07f
3 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/it/test_ifs/test_registry.rs
View file

@ -224,7 +224,7 @@ impl TestRegistry {
name, name,
interface: obj.interface().name(), interface: obj.interface().name(),
version, version,
id: obj.id().into(), id: obj.id(),
})?; })?;
self.tran.add_obj(obj.clone())?; self.tran.add_obj(obj.clone())?;
Ok(()) Ok(())

2
src/it/test_logger.rs
View file

@ -14,7 +14,7 @@ use {
static LEVEL: AtomicUsize = AtomicUsize::new(Level::Info as usize); static LEVEL: AtomicUsize = AtomicUsize::new(Level::Info as usize);
thread_local! { thread_local! {
static FILE: CloneCell<Option<Rc<OwnedFd>>> = CloneCell::new(None); static FILE: CloneCell<Option<Rc<OwnedFd>>> = const { CloneCell::new(None) };
} }
pub fn install() { pub fn install() {

4
src/it/test_transport.rs
View file

@ -200,7 +200,7 @@ struct Outgoing {
} }
impl Outgoing { impl Outgoing {
async fn run(mut self: Self) { async fn run(mut self) {
loop { loop {
self.tc.flush_request.triggered().await; self.tc.flush_request.triggered().await;
if let Err(e) = self.flush().await { if let Err(e) = self.flush().await {
@ -238,7 +238,7 @@ struct Incoming {
} }
impl Incoming { impl Incoming {
async fn run(mut self: Self) { async fn run(mut self) {
loop { loop {
if let Err(e) = self.handle_msg().await { if let Err(e) = self.handle_msg().await {
let msg = format!( let msg = format!(