pub async fn send_and_receive<R>(
    addr: &str,
    request: &RequestMessage<R>,
) -> Result<ResponseMessage<R::Response>, SocketError>
where
    R: Request,
{
    let mut client = FluvioSocket::connect(addr).await?;
    let msgs: ResponseMessage<R::Response> = client.send(request).await?;
    Ok(msgs)
}
/// send request and return response from calling server at socket addr
send request and return response from calling server at socket addr
send request and return response from calling server at socket addr
pub async fn send_and_receive<R>(
    addr: &str,
    request: &RequestMessage<R>,
) -> Result<ResponseMessage<R::Response>, SocketError>
where
    R: Request,
{
    let mut client = FluvioSocket::connect(addr).await?;
    let msgs: ResponseMessage<R::Response> = client.send(request).await?;
    Ok(msgs)
}
pub async fn send_and_receive < R > ( addr : & str , request : & RequestMessage < R > , ) -> Result < ResponseMessage < R :: Response > , SocketError > where R : Request , { let mut client = FluvioSocket :: connect ( addr ) . await ? ; let msgs : ResponseMessage < R :: Response > = client . send ( request ) . await ? ; Ok ( msgs ) }
send request and return response from calling server at socket addr
send request and return response from calling server at socket addr
addr
&str
request
&RequestMessage<R>
addr
&str
request
&RequestMessage<R>