Struct AdaptiveDiscovery 

pub struct AdaptiveDiscovery<D> { /* 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> AdaptiveDiscovery<D>

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

Wraps a discovery stream and clones config into every inserted service.

pub fn into_inner(self) -> D

Consumes the wrapper and returns the original discovery stream.

Trait Implementations

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

where D: TryStream<Ok = Change<K, S>>,

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.

impl<'__pin, D> Unpin for AdaptiveDiscovery<D>

where PinnedFieldsOf<__Origin<'__pin, D>>: Unpin,