Struct tower_discover::ServiceStream

pub struct ServiceStream<S> { /* fields omitted */ }

Dynamic service discovery based on a stream of service changes.

Methods

impl<S> ServiceStream<S>

pub fn new<K, Svc, Request>(services: S) -> Self where
    S: Stream<Item = Change<K, Svc>>,
    K: Hash + Eq,
    Svc: Service<Request>, 

Trait Implementations

impl<S, K, Svc> Discover for ServiceStream<S> where
    K: Hash + Eq,
    S: Stream<Item = Change<K, Svc>>, 

type Key = K

NewService key

type Service = Svc

type Error = S::Error

Error produced during discovery

fn poll(&mut self) -> Poll<Change<Self::Key, Self::Service>, Self::Error>

Yields the next discovery change set.