Struct DeviceWatcherProxy

pub struct DeviceWatcherProxy { /* private fields */ }

Implementations

impl DeviceWatcherProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for fuchsia.lowpan/DeviceWatcher.

pub fn take_event_stream(&self) -> DeviceWatcherEventStream

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

Panics

Panics if the event stream was already taken.

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

Observes when devices are added or removed.

The first call to this method returns immediately with a DeviceChanges struct containing only items in the added field with the names of all of the current devices. Subsequent calls will block until a device has been added or removed, at which point it will return with the added and/or removed fields filled out accordingly. The changes are reported since the time that the method returned.

If both the added and removed fields have names in the returned table, then the removed field MUST be processed BEFORE added field.

If a device was added and then removed in-between calls to this method, the device will be absent from both the added and removed lists.

If the same device name is listed on both the added and removed fields, then the client should assume that the original device was removed and a new device instance started in its place. However, while the client should be able to handle this condition, it should not depend on the server will always have this behavior.

Trait Implementations

impl Clone for DeviceWatcherProxy

fn clone(&self) -> DeviceWatcherProxy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DeviceWatcherProxy

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

Formats the value using the given formatter.

impl DeviceWatcherProxyInterface for DeviceWatcherProxy

type WatchDevicesResponseFut = QueryResponseFut<(Vec<String>, Vec<String>)>

fn watch_devices(&self) -> Self::WatchDevicesResponseFut

impl Proxy for DeviceWatcherProxy

type Protocol = DeviceWatcherMarker

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.