Struct tarpc_lib::server::Channel

pub struct Channel<Req, Resp, T> { /* fields omitted */ }

Responds to all requests with request_handler. The server end of an open connection with a client.

Methods

impl<Req, Resp, T> Channel<Req, Resp, T> where
    T: Transport<Item = ClientMessage<Req>, SinkItem = Response<Resp>> + Send,
    Req: Send,
    Resp: Send, 

pub fn client_addr(&self) -> &SocketAddr

Returns the address of the client connected to the channel.

pub fn respond_with<F, Fut>(self, f: F) -> impl Future<Output = ()> where
    F: FnOnce(Context, Req) -> Fut + Send + 'static + Clone,
    Fut: Future<Output = Result<Resp>> + Send + 'static,
    Req: 'static,
    Resp: 'static, 

Respond to requests coming over the channel with f. Returns a future that drives the responses and resolves when the connection is closed.

Trait Implementations

impl<Req, Resp, T> Drop for Channel<Req, Resp, T>

fn drop(&mut self)

Executes the destructor for this type.

impl<Req: Debug, Resp: Debug, T: Debug> Debug for Channel<Req, Resp, T>

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

Formats the value using the given formatter.