Struct fidl_fuchsia_overnet::ServiceConsumerProxy

pub struct ServiceConsumerProxy { /* private fields */ }

Implementations

impl ServiceConsumerProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for ServiceConsumer

pub fn take_event_stream(&self) -> ServiceConsumerEventStream

Get a Stream of events from the remote end of the ServiceConsumer protocol

Panics

Panics if the event stream was already taken.

pub fn list_peers(&self) -> QueryResponseFut<Vec<Peer>>

Returns a list of all peers that are connected to this Overnet. If this list has not been updated since the last call to this method, it waits until new data is available. Concurrent calls to ListPeers will result in channel closure.

pub fn connect_to_service( &self, node: &mut NodeId, service_name: &str, chan: Channel ) -> Result<(), Error>

Connect chan to some external service on node with name service_name.

Trait Implementations

impl Clone for ServiceConsumerProxy

fn clone(&self) -> ServiceConsumerProxy

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ServiceConsumerProxy

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

Formats the value using the given formatter.

impl Proxy for ServiceConsumerProxy

type Protocol = ServiceConsumerMarker

The protocol which this Proxy controls.

fn from_channel(inner: AsyncChannel) -> Self

Create a proxy over the given channel.

fn into_channel(self) -> Result<AsyncChannel, Self>

Attempt to convert the proxy back into a channel.

fn as_channel(&self) -> &AsyncChannel

Get a reference to the proxy’s underlying channel.

fn is_closed(&self) -> bool

Returns true if the proxy has received the PEER_CLOSED signal.

fn on_closed<'a>(&'a self) -> OnSignals<'a>

Returns a future that completes when the proxy receives the PEER_CLOSED signal.

impl ServiceConsumerProxyInterface for ServiceConsumerProxy

type ListPeersResponseFut = QueryResponseFut<Vec<Peer, Global>>

fn list_peers(&self) -> Self::ListPeersResponseFut

fn connect_to_service( &self, node: &mut NodeId, service_name: &str, chan: Channel ) -> Result<(), Error>