Struct tower_discover::ServiceStream

[+] Show declaration

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

[−] Expand description

Dynamic service discovery based on a stream of service changes.

Implementations

impl<S> ServiceStream<S>[−]

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

Trait Implementations

impl<S: Debug> Debug for ServiceStream<S>[+]

[+] Show hidden undocumented items

fn fmt(&self, f: &mut Formatter<'_>) -> Result[−]

Formats the value using the given formatter.

impl<S, K, Svc> Discover for ServiceStream<S> where
    K: Hash + Eq,
    S: TryStream<Ok = Change<K, Svc>>, [+]

[+] Show hidden undocumented items

type Key = K

NewService key

type Service = Svc

The type of Service yielded by this Discover.

type Error = S::Error

Error produced during discovery

fn poll_discover(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<Change<Self::Key, Self::Service>, Self::Error>>[−]

Yields the next discovery change set.

impl<S> PinnedDrop for ServiceStream<S>[+]

[+] Show hidden undocumented items

unsafe fn drop(self: Pin<&mut Self>)

impl<'pin, S> Unpin for ServiceStream<S> where
    __ServiceStream<'pin, S>: Unpin, 

impl<S> UnsafeUnpin for ServiceStream<S>