/// Sends a message to the engine (will retry idempotently if it fails) which will get forwarded to the peer's engine
/// This is done by sending a POST to /accounts/:id/messages with the provided `message`
/// as the request's body
Sends a message to the engine (will retry idempotently if it fails) which will get forwarded to the peer's engine
This is done by sending a POST to /accounts/:id/messages with the provided `message`
as the request's body
Sends a message to the engine ( will retry idempotently if it fails ) which will get forwarded to the peer ' s engine This is done by sending a POST to / accounts / : id / messages with the provided ` message ` as the request ' s body
pub async fn send_message(&self, id: Uuid, engine_url: Url, message: Vec<u8>) -> Response {
        FutureRetry::new(
            move || self.send_message_once(id, engine_url.clone(), message.clone()),
            RequestErrorHandler::new(self.max_retries),
        )
        .await
        .map(|(response, _attempts)| response)
        .map_err(|(err, _attempts)| err)
    }
pub async fn send_message ( & self , id : Uuid , engine_url : Url , message : Vec < u8 > ) -> Response { FutureRetry :: new ( move | | self . send_message_once ( id , engine_url . clone ( ) , message . clone ( ) ) , RequestErrorHandler :: new ( self . max_retries ) , ) . await . map ( | ( response , _attempts ) | response ) . map_err ( | ( err , _attempts ) | err ) }
Sends a message to the engine (will retry idempotently if it fails) which will get forwarded to the peer's engine
This is done by sending a POST to /accounts/:id/messages with the provided `message`
as the request's body
Sends a message to the engine ( will retry idempotently if it fails ) which will get forwarded to the peer ' s engine This is done by sending a POST to / accounts / : id / messages with the provided ` message ` as the request ' s body
&self
id
Uuid
engine_url
Url
message
Vec<u8>