This commit is contained in:
nora 2022-09-15 21:57:44 +02:00
parent 8779d291ec
commit f3bd42191f
3 changed files with 8 additions and 10 deletions

View file

@ -42,7 +42,7 @@ where
fn(<D::Service as Service<Req>>::Error) -> crate::BoxError, fn(<D::Service as Service<Req>>::Error) -> crate::BoxError,
>; >;
fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { fn poll_ready(&mut self) -> Poll<Result<(), Self::Error>> {
todo!() todo!()
} }
@ -107,7 +107,7 @@ where
type Error = <PinBalance<PoolDiscoverer<MS, Target, Req>, Req> as Service<Req>>::Error; type Error = <PinBalance<PoolDiscoverer<MS, Target, Req>, Req> as Service<Req>>::Error;
type Future = <PinBalance<PoolDiscoverer<MS, Target, Req>, Req> as Service<Req>>::Future; type Future = <PinBalance<PoolDiscoverer<MS, Target, Req>, Req> as Service<Req>>::Future;
fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { fn poll_ready(&mut self) -> Poll<Result<(), Self::Error>> {
todo!() todo!()
} }
@ -118,8 +118,6 @@ where
pub struct DropNotifyService<Svc> { pub struct DropNotifyService<Svc> {
svc: Svc, svc: Svc,
id: usize,
notify: tokio::sync::mpsc::UnboundedSender<usize>,
} }
impl<Svc> Drop for DropNotifyService<Svc> { impl<Svc> Drop for DropNotifyService<Svc> {
@ -140,7 +138,7 @@ impl<Request, Svc: Service<Request>> Service<Request> for DropNotifyService<Svc>
type Future = Svc::Future; type Future = Svc::Future;
type Error = Svc::Error; type Error = Svc::Error;
fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { fn poll_ready(&mut self) -> Poll<Result<(), Self::Error>> {
todo!() todo!()
} }

View file

@ -17,7 +17,7 @@ mod load {
} }
use std::future::Future; use std::future::Future;
use std::task::{Context, Poll}; use std::task::Poll;
pub trait Service<Request> { pub trait Service<Request> {
/// Responses given by the service. /// Responses given by the service.
@ -29,7 +29,7 @@ pub trait Service<Request> {
/// The future response value. /// The future response value.
type Future: Future<Output = Result<Self::Response, Self::Error>>; type Future: Future<Output = Result<Self::Response, Self::Error>>;
fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>; fn poll_ready(&mut self) -> Poll<Result<(), Self::Error>>;
fn call(&mut self, req: Request) -> Self::Future; fn call(&mut self, req: Request) -> Self::Future;
} }

View file

@ -18,7 +18,7 @@ where
type Error = Infallible; type Error = Infallible;
type Future = SharedFuture<S>; type Future = SharedFuture<S>;
fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { fn poll_ready(&mut self) -> Poll<Result<(), Self::Error>> {
todo!() todo!()
} }
@ -40,7 +40,7 @@ where
fn poll( fn poll(
self: std::pin::Pin<&mut Self>, self: std::pin::Pin<&mut Self>,
cx: &mut std::task::Context<'_>, _: &mut std::task::Context<'_>,
) -> std::task::Poll<Self::Output> { ) -> std::task::Poll<Self::Output> {
todo!() todo!()
} }
@ -75,7 +75,7 @@ where
type Future = M::Future; type Future = M::Future;
fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::MakeError>> { fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::MakeError>> {
Service::poll_ready(self, cx) Service::poll_ready(self)
} }
fn make_service(&mut self, target: Target) -> Self::Future { fn make_service(&mut self, target: Target) -> Self::Future {