From 694ce70ce3adef77f8d2a19fbc752f7d72ac886c Mon Sep 17 00:00:00 2001 From: Nilstrieb <48135649+Nilstrieb@users.noreply.github.com> Date: Thu, 15 Sep 2022 22:10:15 +0200 Subject: [PATCH] -m --- tower/src/balance.rs | 16 ---------------- tower/src/lib.rs | 9 ++------- tower/src/make.rs | 9 ++------- 3 files changed, 4 insertions(+), 30 deletions(-) diff --git a/tower/src/balance.rs b/tower/src/balance.rs index f4775ec..cdb1199 100644 --- a/tower/src/balance.rs +++ b/tower/src/balance.rs @@ -41,10 +41,6 @@ where >::Future, fn(>::Error) -> crate::BoxError, >; - - fn poll_ready(&mut self) -> Poll> { - todo!() - } } pub struct PoolDiscoverer @@ -102,21 +98,12 @@ where type Response = , Req> as Service>::Response; type Error = , Req> as Service>::Error; type Future = , Req> as Service>::Future; - - fn poll_ready(&mut self) -> Poll> { - todo!() - } } pub struct DropNotifyService { svc: Svc, } -impl Drop for DropNotifyService { - fn drop(&mut self) { - todo!() - } -} impl Load for DropNotifyService { type Metric = Svc::Metric; @@ -130,7 +117,4 @@ impl> Service for DropNotifyService type Future = Svc::Future; type Error = Svc::Error; - fn poll_ready(&mut self) -> Poll> { - todo!() - } } diff --git a/tower/src/lib.rs b/tower/src/lib.rs index f6b743d..3789eeb 100644 --- a/tower/src/lib.rs +++ b/tower/src/lib.rs @@ -3,6 +3,8 @@ pub mod balance; pub mod make; +use std::future::Future; +use futures_core::TryStream; pub trait Sealed {} /// Alias for a type-erased error type. @@ -15,11 +17,6 @@ mod load { } } -use std::future::Future; -use std::task::Poll; - -use futures_core::TryStream; - pub trait Discover { type Key: Eq; type Service; @@ -54,6 +51,4 @@ pub trait Service { /// The future response value. type Future: Future>; - - fn poll_ready(&mut self) -> Poll>; } diff --git a/tower/src/make.rs b/tower/src/make.rs index bac5875..958277a 100644 --- a/tower/src/make.rs +++ b/tower/src/make.rs @@ -2,7 +2,6 @@ use crate::Sealed; use crate::Service; -use std::task::Poll; use std::convert::Infallible; @@ -17,10 +16,6 @@ where type Response = S; type Error = Infallible; type Future = SharedFuture; - - fn poll_ready(&mut self) -> Poll> { - todo!() - } } pub struct SharedFuture { @@ -29,10 +24,10 @@ pub struct SharedFuture { impl std::future::Future for SharedFuture where - futures_util::future::Ready>: std::future::Future, + std::future::Ready>: std::future::Future, { type Output = - > as std::future::Future>::Output; + > as std::future::Future>::Output; fn poll( self: std::pin::Pin<&mut Self>,