Noratrieb/101844-repro
1
0
Fork 0
mirror of https://github.com/Noratrieb/101844-repro.git synced 2026-01-16 23:15:02 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

yeah

Browse source
This commit is contained in:
nora 2022-09-15 22:45:03 +02:00
parent 292ba1a477
commit 22d798bb53
1 changed files with 20 additions and 25 deletions
Download patch file Download diff file Expand all files Collapse all files

45
tower/src/lib.rs
View file

@ -9,7 +9,7 @@ pub trait Stream {
impl<P> Stream for Pin<P> impl<P> Stream for Pin<P>
where where
P: DerefMut + Unpin, P: DerefMut,
P::Target: Stream, P::Target: Stream,
{ {
type Item = <P::Target as Stream>::Item; type Item = <P::Target as Stream>::Item;
@ -29,9 +29,7 @@ where
pub type BoxError = (); pub type BoxError = ();
pub trait Discover { pub trait Discover {
type Key;
type Service; type Service;
type Error;
} }
impl<K, S, D: ?Sized> Discover for D impl<K, S, D: ?Sized> Discover for D
@ -39,9 +37,7 @@ where
D: TryStream<Ok = (K, S)>, D: TryStream<Ok = (K, S)>,
K: Eq, K: Eq,
{ {
type Key = K;
type Service = S; type Service = S;
type Error = ();
} }
pub trait Service<Request> { pub trait Service<Request> {
@ -49,7 +45,7 @@ pub trait Service<Request> {
type Future; type Future;
} }
pub trait MakeService<Target, Request> { pub trait MakeService<Request> {
type Response; type Response;
type Error; type Error;
type Service: Service<Request, Error = Self::Error>; type Service: Service<Request, Error = Self::Error>;
@ -76,54 +72,53 @@ impl<D, Req> Service<Req> for Balance<D, Req> {
type Future = std::future::Ready<()>; type Future = std::future::Ready<()>;
} }
pub struct PoolDiscoverer<MS, Target, Request> pub struct PoolDiscoverer<MS, Request>
where where
MS: MakeService<Target, Request>, MS: MakeService<Request>,
{ {
_p: PhantomData<(MS, Target, Request)>, _p: PhantomData<(MS, Request)>,
} }
impl<MS, Target, Request> Stream for PoolDiscoverer<MS, Target, Request> impl<MS, Request> Stream for PoolDiscoverer<MS, Request>
where where
MS: MakeService<Target, Request>, MS: MakeService<Request>,
{ {
type Item = (usize, DropNotifyService<MS::Service>); type Item = (usize, SvcWrap<MS::Service>);
} }
pub struct Builder {} pub struct Builder {}
impl Builder { impl Builder {
pub fn build<MS, Target, Request>() pub fn build<MS, Request>()
where where
MS: MakeService<Target, Request>, MS: MakeService<Request>,
MS::Error: Into<crate::BoxError>, MS::Error: Into<crate::BoxError>,
{ {
let d: PoolDiscoverer<MS, Target, Request> = todo!(); let d: PoolDiscoverer<MS, Request> = todo!();
// THE CRITICAL STATEMENT // THE CRITICAL STATEMENT
let _ = Balance::new(Box::pin(d)); let _ = Balance::new(Box::pin(d));
} }
} }
pub struct Pool<MS, Target, Request> { pub struct Pool<MS, Request> {
balance: (MS, Target, Request), balance: (MS, Request),
} }
impl<MS, Target, Req> Service<Req> for Pool<MS, Target, Req> impl<MS, Req> Service<Req> for Pool<MS, Req>
where where
MS: MakeService<Target, Req>, MS: MakeService<Req>,
MS::Error: Into<crate::BoxError>, MS::Error: Into<crate::BoxError>,
Target: Clone,
{ {
type Error = <Balance<PoolDiscoverer<MS, Target, Req>, Req> as Service<Req>>::Error; type Error = <Balance<PoolDiscoverer<MS, Req>, Req> as Service<Req>>::Error;
type Future = <Balance<PoolDiscoverer<MS, Target, Req>, Req> as Service<Req>>::Future; type Future = <Balance<PoolDiscoverer<MS, Req>, Req> as Service<Req>>::Future;
} }
pub struct DropNotifyService<Svc> { pub struct SvcWrap<Svc> {
svc: Svc, svc: Svc,
} }
impl<Request, Svc: Service<Request>> Service<Request> for DropNotifyService<Svc> { impl<Request, Svc: Service<Request>> Service<Request> for SvcWrap<Svc> {
type Future = Svc::Future; type Future = Svc::Future;
type Error = Svc::Error; type Error = Svc::Error;
} }