П
Ну и вроде всё
Size: a a a
2021 July 12
DF
ааа, даже так
П
Ну это просто чтобы оно нужные маркеры проставило
2021 July 16
S
Привет. А есть ли возможность используя tokio::sync::mpsc::Receiver проверить канал сейчас пуст или нет?
П
len() мб есть
DO
ReceiverStream + Peekable + poll_peek()?
П
плохо
IB
Он может вернуть значение, которое обратно не запихаешь. Это не то же самое, что просто узнать.
MB
А зачем ты хочешь это сделать? Его состояние может сразу же поменяться после выполнения такой проверки.
S
чтобы забрать из канал все что сейчас есть одной пачкой
S
если просто вызвать recv().wait, то будет ждать пока не появится следующий евент
D
тут в ближайшее время студент из ВШЭ скинет опрос айтишнегов, не пужайтесь)
DO
Обычно в таких случаях обрабатывают пачку, если либо набралось максимальное количество, либо прошло определеное время после первого в текущей пачке. И ждут с таймаутом, который отсчитывают от времени появление первого.
S
так оно и работает. После таймаута собиратеся пачка из того что сейчас в канале. Но чтобы это сделать нужно знать есть сейчас еще ивенты в канале или нет
П
select!
П
Правда я хз насколько этот канал адекватно на отмену реагирует
ph
почему poll_recv не подходит тогда?
ph
ему и не надо ничего обратно запихивать