Struct ExternalServiceProxy 

pub struct ExternalServiceProxy<P, Publisher>
where
    P: Proxy,
{ /* private fields */ }

A wrapper around a proxy, used to track disconnections.

This wraps any type implementing Proxy. Whenever any call returns a ClientChannelClosed error, this wrapper publishes a closed event for the wrapped proxy.

Implementations

impl<P, Publisher> ExternalServiceProxy<P, Publisher>

where P: Proxy, Publisher: EventPublisher,

pub fn new(proxy: P, publisher: Option<Publisher>) -> Self

pub fn inspect_result<T>( &self, result: &Result<T, Error>, arg_str: String, req_timestamp: String, resp_timestamp: String, )

where T: Debug,

Handle the result of the event sent via the call or call_async methods and send the corresponding information to be logged to inspect.

pub fn call<T, F>(&self, func: F, arg_str: String) -> Result<T, Error>

where F: FnOnce(&P) -> Result<T, Error>, T: Debug,

Make a call to a synchronous API of the wrapped proxy. This should not be called directly, only from the call macro.

pub async fn call_async<T, F, Fut>( &self, func: F, arg_str: String, ) -> Result<T, Error>

where F: FnOnce(&P) -> Fut, Fut: Future<Output = Result<T, Error>>, T: Debug,

Make a call to an asynchronous API of the wrapped proxy. This should not be called directly, only from the call_async macro.

Trait Implementations

impl<P, Publisher: Clone> Clone for ExternalServiceProxy<P, Publisher>

where P: Proxy + Clone,

fn clone(&self) -> ExternalServiceProxy<P, Publisher>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P, Publisher: Debug> Debug for ExternalServiceProxy<P, Publisher>

where P: Proxy + Debug,

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

Formats the value using the given formatter.