Struct SuiteControllerSynchronousProxy

pub struct SuiteControllerSynchronousProxy { /* private fields */ }

Implementations

impl SuiteControllerSynchronousProxy

pub fn new(channel: Channel) -> Self

pub fn into_channel(self) -> Channel

pub fn wait_for_event( &self, deadline: MonotonicInstant, ) -> Result<SuiteControllerEvent, Error>

Waits until an event arrives and returns it. It is safe for other threads to make concurrent requests while waiting for an event.

pub fn stop(&self) -> Result<(), Error>

Stop the suite run gracefully. SuiteController will disconnect after all resources are released and all the events in this controller are drained.

pub fn kill(&self) -> Result<(), Error>

Immediately terminate the run. SuiteController will disconnect after all resources are released. This method will terminate tests even if they are in progress.

pub fn watch_events( &self, ___deadline: MonotonicInstant, ) -> Result<SuiteControllerWatchEventsResult, Error>

Returns events when they’re available using a hanging get pattern. Returns an empty vector to indicate there will be no further events.

pub fn get_events( &self, ___deadline: MonotonicInstant, ) -> Result<SuiteControllerGetEventsResult, Error>

Iterator over events for the run. This method is a hanging get; it returns an empty vector only when there will be no further events (the run completed).

Trait Implementations

impl Debug for SuiteControllerSynchronousProxy

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

Formats the value using the given formatter.

impl SynchronousProxy for SuiteControllerSynchronousProxy

type Proxy = SuiteControllerProxy

The async proxy for the same protocol.

type Protocol = SuiteControllerMarker

The protocol which this Proxy controls.

fn from_channel(inner: Channel) -> Self

Create a proxy over the given channel.

fn into_channel(self) -> Channel

Convert the proxy back into a channel.

fn as_channel(&self) -> &Channel

Get a reference to the proxy’s underlying channel.

fn is_closed(&self) -> Result<bool, Status>

Returns true if the proxy has received the PEER_CLOSED signal.