tokio-tower 0.7.0-rc3

Bridging the protocol gap between Tokio and Tower
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use futures_core::stream::TryStream;
use futures_sink::Sink;

pub(crate) struct ClientRequest<T, I>
where
    T: Sink<I> + TryStream,
{
    pub(crate) req: I,
    pub(crate) span: tracing::Span,
    pub(crate) res: tokio::sync::oneshot::Sender<ClientResponse<T::Ok>>,
}

pub(crate) struct ClientResponse<T> {
    pub(crate) response: T,
    pub(crate) span: tracing::Span,
}