Struct NotificationProxyClient 

pub struct NotificationProxyClient<S> { /* private fields */ }

Implementations

impl<S: AsyncRead + AsyncWrite + Unpin> NotificationProxyClient<S>

pub fn new(stream: S) -> Self

pub async fn observe( &mut self, notification: &str, ) -> Result<(), NotificationProxyError>

pub async fn post( &mut self, notification: &str, ) -> Result<(), NotificationProxyError>

pub async fn wait_for( &mut self, notification: &str, timeout: Duration, ) -> Result<(), NotificationProxyError>

pub async fn wait_for_springboard( &mut self, timeout: Duration, ) -> Result<(), NotificationProxyError>

pub async fn next_event( &mut self, timeout: Duration, ) -> Result<NotificationProxyEvent, NotificationProxyError>

pub async fn shutdown(&mut self) -> Result<(), NotificationProxyError>

pub async fn recv_event( &mut self, ) -> Result<NotificationEvent, NotificationProxyError>

Trait Implementations

impl<S: Debug> Debug for NotificationProxyClient<S>

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

Formats the value using the given formatter.