pub trait RpcClientLocal {
// Required methods
async fn invoke<H: CommandCustomHeader + TopicRequestHeaderTrait>(
&self,
request: RpcRequest<H>,
timeout_millis: u64,
) -> RocketMQResult<RpcResponse>;
async fn invoke_mq<H: CommandCustomHeader + TopicRequestHeaderTrait>(
&self,
mq: MessageQueue,
request: RpcRequest<H>,
timeout_millis: u64,
) -> RocketMQResult<RpcResponse>;
}Required Methods§
async fn invoke<H: CommandCustomHeader + TopicRequestHeaderTrait>( &self, request: RpcRequest<H>, timeout_millis: u64, ) -> RocketMQResult<RpcResponse>
async fn invoke_mq<H: CommandCustomHeader + TopicRequestHeaderTrait>( &self, mq: MessageQueue, request: RpcRequest<H>, timeout_millis: u64, ) -> RocketMQResult<RpcResponse>
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.