ph
Size: a a a
2021 May 18
П
https://docs.rs/tokio/1.2.0/tokio/io/trait.AsyncRead.html я эту имел в виду
П
Но я не уверен что оно поэтому может broken pipe кидать
KS
Хм, ок, спасибо, попробую. Я правильно понимаю, что try_read блочит выполнение, когда нет входящего стрима, а read не блочит?
ph
неправильно
try_read не блочит ничего
read "блочит" футуру
try_read не блочит ничего
read "блочит" футуру
П
try_read это типа как руками poll дергать?
MB
Ну да, но тут тебя даже не уведомят, что снова можно читать
KS
Так, я поменяла на read и разобралась, почему был broken pipe. Оказывается, я неправильно парсила реквест, теперь через json все хорошо. Но только вот все равно клиент не лупается, один раз проходит loop и дальше отключается (если использовать tokio::spawn) или просто проходит один раз и замирает (если просто loop).
D
а зачем нужен вшений
tokio::spawn(async move { ?KS
На стак оверфлоу для постоянного клиента пишут использовать loop_fn из futures, но он уже deprecated.
D
спавнить нужно обработку каждого клиента, а приём соединение делать во внешнем цикле
D
а, это не сервер, а клиент
D
в общем, spawn тут точно не нужен
D
получается, что футура спавнится, но после этого приложение тут же завершается
KS
Ок, поняла. Без spawn все равно не работает. По сути, я хочу, чтобы постоянно в цикле сначала чекалось наличие входных сообщений, если они есть, то отправляем на апи. И после чекаем на наличие сообщений на апи, если они есть, то пишем в стрим. Но почему-то после первого прохода клиент замирает и ничего не делает.
D
а на каком месте замирает?
D
можно на худой конец просто принты расставить :)
ph
пахнет select'ом
KS
После того, как получил первое сообщение в стриме, отправил гет и получил пустой ответ, в 85 строке, хотя там по идее дальше continue, должен начать очередной луп