pub fn stream_reply<T, E>(
    buffer_size: usize
) -> (ReplyStreamHandle<T>, ReplyStreamFuture<T, E>)