Struct abstract_ns::combinators::FrozenSubscriber

pub struct FrozenSubscriber<R> { /* fields omitted */ }

A subscriber that resolves once and never updates the result

You can create it with Resolve::frozen_subscriber

Trait Implementations

impl<R: Debug> Debug for FrozenSubscriber<R>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<R: Resolve> Resolve for FrozenSubscriber<R>

type Future = R::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: Resolve + Sized, 

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<R: Resolve> Subscribe for FrozenSubscriber<R>

type Stream = StreamOnce<R::Future>

A stream returned from subscribe()

type Error = <R::Future as Future>::Error

An error type returned by a stream

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

Resolve a name and subscribe to the updates

impl<R: HostResolve> HostResolve for FrozenSubscriber<R>

type HostFuture = R::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<R: HostResolve> HostSubscribe for FrozenSubscriber<R>

type HostStream = StreamOnce<R::HostFuture>

A stream returned from subscribe()

type HostError = <R::HostFuture as Future>::Error

An error type returned by a stream

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

Resolve a name and subscribe to the updates