Struct AdaptiveDiscovery 

pub struct AdaptiveDiscovery<D, Request> { /* private fields */ }

Maps a Tower discovery stream into freshly initialized adaptive endpoints.

The wrapper intentionally creates new controller state for every insert. This is the safe behavior when discovery removes and later reuses an endpoint key; state retention can be added without changing the discovery contract once churn behavior is better understood.

Implementations

impl<D, Request> AdaptiveDiscovery<D, Request>

pub fn new(inner: D, config: EndpointConfig) -> Self

pub fn into_inner(self) -> D

Trait Implementations

impl<D, Request, K, S> Stream for AdaptiveDiscovery<D, Request>

where D: TryStream<Ok = Change<K, S>> + Unpin, K: Eq, S: Service<Request> + Send + 'static, S::Future: Send + 'static, S::Response: Send + 'static, S::Error: Send + 'static, Request: 'static,

type Item = Result<Change<K, AdaptiveEndpoint<S>>, <D as TryStream>::Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.