Struct DestructionWatcherProxy 

pub struct DestructionWatcherProxy { /* private fields */ }

Implementations

impl DestructionWatcherProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for fuchsia.net.sockets/DestructionWatcher.

pub fn take_event_stream(&self) -> DestructionWatcherEventStream

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

Panics

Panics if the event stream was already taken.

pub fn watch( &self, ) -> QueryResponseFut<Vec<IpSocketState>, DefaultFuchsiaResourceDialect>

Hanging get for destroyed sockets.

Returns sockets destroyed since the last call to this method. Blocks until at least one event is available.

A “destroyed” socket is one that no longer has any references inside the Netstack. Especially for TCP sockets (because of TIME-WAIT), this may happen long after close has returned.

Sockets destroyed before the watcher was created are not returned. Unbound sockets are not returned.

Only one call to Watch may be active at a time. Concurrency is not allowed and will result in the channel being closed with ALREADY_EXISTS.

If the client doesn’t read events fast enough, the channel is closed with NO_RESOURCES.

Trait Implementations

impl Clone for DestructionWatcherProxy

fn clone(&self) -> DestructionWatcherProxy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DestructionWatcherProxy

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

Formats the value using the given formatter.

impl DestructionWatcherProxyInterface for DestructionWatcherProxy

type WatchResponseFut = QueryResponseFut<Vec<IpSocketState>>

fn watch(&self) -> Self::WatchResponseFut

impl Proxy for DestructionWatcherProxy

type Protocol = DestructionWatcherMarker

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<'_, NullableHandle>>

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