Помоему супер первая страничка!)

Ещё гайд завезли

О, посмотрю на днях! 👍

🤟

https://github.com/rust-lang/rfcs/pull/2958#issuecomment-662501188
meh

Есть вопрос по Токийскому селекту.

Предусловие:

Есть TCP-сервер, необходимо поддерживать соединение с клиентом, путем получения от него keepalive-хартбитов.

Если в промежутке заданного таймаута не приходит необходимая команда - дропать соединение, если же приходит - то обновлять таймаут.

Моя имплементация -

при создании хэндлера:

tokio::spawn(async move {
    let mut delay =
        tokio::time::delay_for(Duration::from_secs(timeout));

    loop {
        select! {
            _ = &mut delay => {
                timeout_tx.send(());
                break;
            }
            next = ch_rx.next() => {
                // When sender handles are dropped, next will return Ok(None)
                // So we check if next has actual value, to reset delay
                // Otherwise that means that sender was dropped (because parent struct was dropped) and so we end this task
                if next.is_some() {
                    delay = tokio::time::delay_for(Duration::from_millis(timeout));
                } else {
                    break;
                }
            }
        }
    }
});

в самом хэндлере:

loop {
    // run concurrently timeout receiver and decoder, getting messages and handling them
    select! {
        _ = &mut timeout_rx => {
            return Err(anyhow::anyhow!("Client disconnected because of timeout!"));
        }
        res = self.socket.next() => {
            if let Some(parsed) = res {
                self.handle(parsed?).await?;
            } else {
                return Err(anyhow::anyhow!("Client disconnected!"));
            }
        }
    }
}

нормально ли то - что у меня селект крутится внутри лупа? или же стоит вынести наружу селект в первом спавне, учитывая что в любом случае обе футуры будут возвращать пендинг, пока либо не обновится таймаут, либо он не истечет?

мб на стрим повесить .timeout?
https://docs.rs/tokio/0.2.22/tokio/stream/trait.StreamExt.html#method.timeout

так не получится, потому что мне нужно обновлять таймаут только при определенной команде

то есть клиент может слать любые команды, но не послать CHECK, в таком случае его все равно надо дропать

а

странно, но ладно

(обычно хартбит шлют только когда обычных сообщений нет)

                if next.is_some() {
                    delay = tokio::time::delay_for(Duration::from_millis(timeout));

по-моему ты безусловно delay отодвигаешь

ну, независимо от того, что там в канал пришло

аааааааааааааааа

ну да, потому что там ()

ппц ты хитро сделал

эдакий CancellationToken

))