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>,