Struct StressorProxy

pub struct StressorProxy { /* private fields */ }

Implementations

impl StressorProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for test.proxy.stress/Stressor.

pub fn take_event_stream(&self) -> StressorEventStream

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

Panics

Panics if the event stream was already taken.

pub fn stuff_socket( &self, socket: Socket, ) -> QueryResponseFut<u32, DefaultFuchsiaResourceDialect>

Writes 0xFF repeatedly to the given socket until the buffer is full, then returns the number of bytes written. The client should not read from the other end of the socket until this returns.

pub fn echo( &self, content: &str, ) -> QueryResponseFut<String, DefaultFuchsiaResourceDialect>

Trait Implementations

impl Clone for StressorProxy

fn clone(&self) -> StressorProxy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StressorProxy

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

Formats the value using the given formatter.

impl Proxy for StressorProxy

type Protocol = StressorMarker

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.

impl StressorProxyInterface for StressorProxy

type StuffSocketResponseFut = QueryResponseFut<u32>

type EchoResponseFut = QueryResponseFut<String>

fn stuff_socket(&self, socket: Socket) -> Self::StuffSocketResponseFut

fn echo(&self, content: &str) -> Self::EchoResponseFut