Struct FakeEndpointProxy

pub struct FakeEndpointProxy { /* private fields */ }

Implementations

impl FakeEndpointProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for fuchsia.netemul.network/FakeEndpoint.

pub fn take_event_stream(&self) -> FakeEndpointEventStream

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

Panics

Panics if the event stream was already taken.

pub fn write( &self, data: &[u8], ) -> QueryResponseFut<(), DefaultFuchsiaResourceDialect>

Writes a frame to the network.

pub fn read( &self, ) -> QueryResponseFut<(Vec<u8>, u64), DefaultFuchsiaResourceDialect>

Reads a single frame from the network.

Blocks until new data is available to be read. FakeEndpoint will keep a limited amount of frames to be read, dropping the oldest ones if the data is not fetched fast enough. The number of dropped frames since the last call to Read is returned in dropped_frames.

Issuing a second Read request when the first one is still pending will cause the channel to be closed with ZX_ERR_BAD_STATE.

Trait Implementations

impl Clone for FakeEndpointProxy

fn clone(&self) -> FakeEndpointProxy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for FakeEndpointProxy

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

Formats the value using the given formatter.

impl FakeEndpointProxyInterface for FakeEndpointProxy

type WriteResponseFut = QueryResponseFut<()>

type ReadResponseFut = QueryResponseFut<(Vec<u8>, u64)>

fn write(&self, data: &[u8]) -> Self::WriteResponseFut

fn read(&self) -> Self::ReadResponseFut

impl Proxy for FakeEndpointProxy

type Protocol = FakeEndpointMarker

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.