pub fn stream_request<T, R>(
    buffer: usize
) -> (RequestStreamHandle<T, R>, RequestSink<T>, ReplyFuture<R>)