pub struct PublisherProxy { /* private fields */ }
Implementations§
Source§impl PublisherProxy
impl PublisherProxy
Sourcepub fn take_event_stream(&self) -> PublisherEventStream
pub fn take_event_stream(&self) -> PublisherEventStream
Get a Stream of events from the remote end of the protocol.
§Panics
Panics if the event stream was already taken.
Sourcepub fn publish_service_instance(
&self,
service: &str,
instance: &str,
media: Media,
perform_probe: bool,
publication_responder: ClientEnd<PublicationResponder_Marker>,
) -> QueryResponseFut<PublisherPublishServiceInstanceResult, DefaultFuchsiaResourceDialect>
pub fn publish_service_instance( &self, service: &str, instance: &str, media: Media, perform_probe: bool, publication_responder: ClientEnd<PublicationResponder_Marker>, ) -> QueryResponseFut<PublisherPublishServiceInstanceResult, DefaultFuchsiaResourceDialect>
Publishes a service instance. publication_responder
is consulted via its
OnPublication
method for initial announcements and to answer queries.
The service is published until the publication_responder
channel closes. In
addition to announcements and queries for the service type, all queries
for subtypes are answered subject to filtering through the responder.
perform_probe
indicates whether a probe for a conflicting instance
should be performed before publishing the instance. This value should
be true
unless the instance name is known to be unique.
If a service with the same service and instance names is already published, the old publication will be terminated, and the responder channel for the old publication will be closed.
Trait Implementations§
Source§impl Clone for PublisherProxy
impl Clone for PublisherProxy
Source§fn clone(&self) -> PublisherProxy
fn clone(&self) -> PublisherProxy
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Debug for PublisherProxy
impl Debug for PublisherProxy
Source§impl Proxy for PublisherProxy
impl Proxy for PublisherProxy
Source§type Protocol = PublisherMarker
type Protocol = PublisherMarker
Proxy
controls.Source§fn from_channel(inner: AsyncChannel) -> Self
fn from_channel(inner: AsyncChannel) -> Self
Source§fn into_channel(self) -> Result<AsyncChannel, Self>
fn into_channel(self) -> Result<AsyncChannel, Self>
Source§fn as_channel(&self) -> &AsyncChannel
fn as_channel(&self) -> &AsyncChannel
§fn into_client_end(self) -> Result<ClientEnd<Self::Protocol>, Self>
fn into_client_end(self) -> Result<ClientEnd<Self::Protocol>, Self>
Source§impl PublisherProxyInterface for PublisherProxy
impl PublisherProxyInterface for PublisherProxy
type PublishServiceInstanceResponseFut = QueryResponseFut<Result<(), Error>>
fn publish_service_instance( &self, service: &str, instance: &str, media: Media, perform_probe: bool, publication_responder: ClientEnd<PublicationResponder_Marker>, ) -> Self::PublishServiceInstanceResponseFut
Auto Trait Implementations§
impl Freeze for PublisherProxy
impl !RefUnwindSafe for PublisherProxy
impl Send for PublisherProxy
impl Sync for PublisherProxy
impl Unpin for PublisherProxy
impl !UnwindSafe for PublisherProxy
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)