D
локальный "плэйграунд" сетапится за 3 секунды через
cargo new --bin ... :)Size: a a a
2021 October 24
LB
попытался сделать пример для T: Sink<i32> + Stream<Item = i32> запутался в тысячах ошибок компиляции. вобщем пока про split не узнал, накодил что-то рабочеее, не так как хотелось бы, когда просто две футуры в select!, но тоже ничего. Как буду побыстрее с растом, спрошу ещё раз или сам уже разбирусь.
2021 October 26
LB
я правильно понимаю, что какой-нибудь
в
listener.accept().and_then(|(tcp, _addr)| app_handshake(tcp))в
tokio::select! запихнуть нельзя, потому что оно не cancelation safe?D
почему нельзя? законы физики и языка не запрещают + что именно там не cancellation safe?
D
как минимум в доке про
accept явно написано, что он cancel safeLB
accept да, но не весь комбинатор
D
app_handshake не cancel safe?LB
не важно, стейт между accept и app_handshake потеряется же на следующей итерации
D
что за стейт между ними? О_о
LB
иными словами нельзя:
пихать в select
async { a = afut.await; bfut(a).await }пихать в select
D
почему нельзя-то?
D
у тебя какие-то данные потеряются? эти функции пишут стейт в какие-то глобалки? нет? значит всё ок
LB
потому что вся футура пересоздается меджу итерациями
D
ну и что?
LB
ну и
a = afut.await потеряется, не дойдя до bfutD
ну и что?)
D
и что значит "потеряется"? это же не мягкая игрушка в детской комнате)
LB
ну если afut это accept, то оно создаст дескриптор, который дропнется и коннект порвётся
D
иии???
LB
ну что и :) клиент получит отлуп на ровном месте , connection reset всё такое