extending timeout during body read

[PAStheLoD]

Hello,

I'm writing an SSE (server-sent events) client that processes a chunked response, with a server-supplied expected max time. So it'd be great to be able to reset the timeout when a new message is received. Is this possible currently? (If not then this is a request for enhancement :))

Last but not least, many thanks for this great library!

[algesten]

Hello @PAStheLoD! Welcome to ureq!

Do I get this right, you want to be able to set the socket.set_read_timeout(n) also after you sent the request, i.e. when you have the Response object?

[PAStheLoD]

I'm not familiar with the low-level API, but something like that, yes :)

An excerpt from the current version:

use std::io::{BufRead, BufReader, Write};


// ...

    let result = ureq::get(&conf.url)
        .timeout(Duration::from_secs(conf.first_byte_timeout_sec as u64))
        .call();



     match result {
         Ok(response) => process(response)
         Err ...
     }


fn process(response: Response) {
    let mut buf: Vec<String> = Vec::with_capacity(10);

    let reader = response.into_reader();
  
    let bufreader = BufReader::new(reader);

    for line in bufreader.lines() {
        // match ..
        // ... I guess this is where I'd reset the timeout after each "line"
    }
}

Thanks again!

[algesten]

Help wanted. It can be implemented using Body::reset_body_timeout() or something.