From 986246026094d27dd5cc8cff3d9f5c71b23d3ed8 Mon Sep 17 00:00:00 2001 From: Nikolay Kim Date: Thu, 12 Aug 2021 08:33:58 +0600 Subject: [PATCH] remove dead code --- src/lib.rs | 2 +- src/router.rs | 51 --------------------------------------------------- 2 files changed, 1 insertion(+), 52 deletions(-) diff --git a/src/lib.rs b/src/lib.rs index db3e00c..3698717 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -1,4 +1,4 @@ -#![deny(rust_2018_idioms, unreachable_pub)] +#![deny(rust_2018_idioms)] #![allow(clippy::type_complexity)] #[macro_use] diff --git a/src/router.rs b/src/router.rs index d74dcda..b9b2070 100644 --- a/src/router.rs +++ b/src/router.rs @@ -289,57 +289,6 @@ impl Future for RouterServiceResponse { } } -struct HandleMessage { - link: ReceiverLink, - delivery_id: DeliveryNumber, - fut: Pin>>>, -} - -impl Future for HandleMessage { - type Output = (); - - fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll { - let mut this = self.as_mut(); - - match Pin::new(&mut this.fut).poll(cx) { - Poll::Pending => Poll::Pending, - Poll::Ready(Ok(outcome)) => { - log::trace!( - "Outcome is ready {:?} for {}", - outcome, - this.link - .frame() - .target - .as_ref() - .map_or("", |t| t.address.as_ref().map_or("", AsRef::as_ref)) - ); - let delivery_id = this.delivery_id; - settle(&mut this.link, delivery_id, outcome.into_delivery_state()); - Poll::Ready(()) - } - Poll::Ready(Err(e)) => { - log::trace!( - "Outcome is failed {:?} for {}", - e, - this.link - .frame() - .target - .as_ref() - .map_or("", |t| t.address.as_ref().map_or("", AsRef::as_ref)) - ); - - let delivery_id = this.delivery_id; - settle( - &mut this.link, - delivery_id, - DeliveryState::Rejected(Rejected { error: Some(e) }), - ); - Poll::Ready(()) - } - } - } -} - fn settle(link: &mut ReceiverLink, id: DeliveryNumber, state: DeliveryState) { let disposition = Disposition { state: Some(state),