Struct BusProxy

pub struct BusProxy { /* private fields */ }

Implementations

impl BusProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for fuchsia.netemul.sync/Bus.

pub fn take_event_stream(&self) -> BusEventStream

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

Panics

Panics if the event stream was already taken.

pub fn publish(&self, data: &Event) -> Result<(), Error>

Publishes event on the bus.

pub fn ensure_publish( &self, data: &Event, ) -> QueryResponseFut<(), DefaultFuchsiaResourceDialect>

Publishes data on bus and only returns when data has been dispatched. Use this if you need guarantees that the data was broadcast before continuing. Note that this ensures that the data will be published to all listening clients, but it cannot guarantee that all clients will have observed the event before it returns.

pub fn get_clients( &self, ) -> QueryResponseFut<Vec<String>, DefaultFuchsiaResourceDialect>

Get list of named clients.

pub fn wait_for_clients( &self, clients: &[String], timeout: i64, ) -> QueryResponseFut<(bool, Option<Vec<String>>), DefaultFuchsiaResourceDialect>

Waits for up to timeout (nsec) for all the clients in clients. Returns true if all clients are present on the bus before timeout expired. If result is false, absent will contain the entries in clients that still weren’t present on the bus when the timout expired. Use timeout <= 0 for indefinite wait.

pub fn wait_for_event_( &self, data: &Event, timeout: i64, ) -> QueryResponseFut<bool, DefaultFuchsiaResourceDialect>

Waits for up to timeout (nsec) for an event that matches data. Event equality is performed by comparing all set fields in data. Returns true if event was received before timeout expired. Use timeout <= 0 for indefinite wait.

Trait Implementations

impl BusProxyInterface for BusProxy

type EnsurePublishResponseFut = QueryResponseFut<()>

type GetClientsResponseFut = QueryResponseFut<Vec<String>>

type WaitForClientsResponseFut = QueryResponseFut<(bool, Option<Vec<String>>)>

type WaitForEvent_ResponseFut = QueryResponseFut<bool>

fn publish(&self, data: &Event) -> Result<(), Error>

fn ensure_publish(&self, data: &Event) -> Self::EnsurePublishResponseFut

fn get_clients(&self) -> Self::GetClientsResponseFut

fn wait_for_clients( &self, clients: &[String], timeout: i64, ) -> Self::WaitForClientsResponseFut

fn wait_for_event_( &self, data: &Event, timeout: i64, ) -> Self::WaitForEvent_ResponseFut

impl Clone for BusProxy

fn clone(&self) -> BusProxy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for BusProxy

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

Formats the value using the given formatter.

impl Proxy for BusProxy

type Protocol = BusMarker

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 into_client_end(self) -> Result<ClientEnd<Self::Protocol>, Self>

Attempt to convert the proxy back into a client end.

fn is_closed(&self) -> bool

Returns true if the proxy has received the PEER_CLOSED signal.

fn on_closed(&self) -> OnSignals<'_, Unowned<'_, Handle>>

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