Function stream_reader_task 

async fn stream_reader_task<R>(
    server: Arc<Server>,
    reader: R,
    conn: ConnState,
    read_timeout: Option<Duration>,
) -> Result<()>
where
    R: MessageRx<Message = Value> + Send,