Struct RunControllerSynchronousProxy

pub struct RunControllerSynchronousProxy { /* private fields */ }

Implementations

impl RunControllerSynchronousProxy

pub fn new(channel: Channel) -> Self

pub fn into_channel(self) -> Channel

pub fn wait_for_event( &self, deadline: MonotonicInstant, ) -> Result<RunControllerEvent, 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 run gracefully. RunController will disconnect after all resources are released and all the events in this controller are drained. This method is used to allow the run to complete tests that are in progress, but will prevent starting new tests.

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

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

pub fn get_events( &self, ___deadline: MonotonicInstant, ) -> Result<Vec<RunEvent>, 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 RunControllerSynchronousProxy

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

Formats the value using the given formatter.

impl SynchronousProxy for RunControllerSynchronousProxy

type Proxy = RunControllerProxy

The async proxy for the same protocol.

type Protocol = RunControllerMarker

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.