Function response_reader_with_timeout 

pub fn response_reader_with_timeout<R: AsyncRead + Unpin>(
    reader: R,
    timeout: Duration,
) -> AgentResponseReader<R>