Trait dubbo::protocol::Invoker

pub trait Invoker<ReqBody>: Debug {
    type Response;
    type Error;
    type Future: Future<Output = Result<Self::Response, Self::Error>>;

    // Required methods
    fn get_url(&self) -> Url;
    fn poll_ready(
        &mut self,
        cx: &mut Context<'_>
    ) -> Poll<Result<(), Self::Error>>;
    fn call(&mut self, req: ReqBody) -> Self::Future;
}

Required Associated Types

type Response

type Error

type Future: Future<Output = Result<Self::Response, Self::Error>>

Required Methods

fn get_url(&self) -> Url

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

fn call(&mut self, req: ReqBody) -> Self::Future

Implementors

impl Invoker<Request<SdkBody>> for TripleInvoker

type Response = Response<UnsyncBoxBody<Bytes, Status>>

type Error = Box<dyn Error + Send + Sync + 'static, Global>

type Future = Pin<Box<dyn Future<Output = Result<<TripleInvoker as Invoker<Request<SdkBody>>>::Response, <TripleInvoker as Invoker<Request<SdkBody>>>::Error>> + Send + 'static, Global>>