Struct IntervalSubscriber

pub struct IntervalSubscriber<R>(/* private fields */);

A subscriber which polls resolver at a regular interval

Create the instance with SubscribeExt::interval_subscriber

Trait Implementations

impl<R: Debug> Debug for IntervalSubscriber<R>

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

Formats the value using the given formatter.

impl<T: HostResolve> HostResolve for IntervalSubscriber<T>

type HostFuture = <T as HostResolve>::HostFuture

A future returned from resolve()

fn resolve_host(&self, name: &Name) -> Self::HostFuture

Resolve a name to an address once

fn frozen_host_subscriber(self) -> FrozenSubscriber<Self>

where Self: Sized,

Create a subscriber that resolves once using this resolver and never updates a stream

fn null_service_resolver(self) -> NullResolver<Self>

where Self: Sized,

Create a thing that implements Resolve+HostResolve but returns NameNotFound on resolve

impl<T: HostResolve> HostSubscribe for IntervalSubscriber<T>

type HostError = <<T as HostResolve>::HostFuture as Future>::Error

An error type returned by a stream

type HostStream = IntervalHostResolver<T>

A stream returned from subscribe()

fn subscribe_host(&self, name: &Name) -> Self::HostStream

Resolve a name and subscribe to the updates

impl<T: Resolve> Resolve for IntervalSubscriber<T>

type Future = <T as Resolve>::Future

A future returned from resolve()

fn resolve(&self, name: &Name) -> Self::Future

Resolve a name to an address once

fn frozen_subscriber(self) -> FrozenSubscriber<Self>

where Self: Sized + Resolve,

Create a subscriber that resolves once using this resolver and never updates a stream

fn frozen_service_subscriber(self) -> FrozenSubscriber<Self>

where Self: Sized,

Create a subscriber that resolves once using this resolver and never updates a stream

fn null_host_resolver(self) -> NullHostResolver<Self>

where Self: Sized,

Create a thing that implements Resolve+HostResolve but returns NameNotFound on resolve_host

impl<T: Resolve> Subscribe for IntervalSubscriber<T>

type Error = <<T as Resolve>::Future as Future>::Error

An error type returned by a stream

type Stream = IntervalResolver<T>

A stream returned from subscribe()

fn subscribe(&self, name: &Name) -> Self::Stream

Resolve a name and subscribe to the updates