Size: a a a

2020 July 01

m

mAX in Rust Async
но она не получает сообщения из spawn.. только первое, которое скорее всего было записано до запуска фьючи server
источник

m

mAX in Rust Async
а tick 2 как раз потому что 0 прочиталось, 1 записалось в буффур, а после 2 повис цикл на отправке await
тк буффер размером 1 элемент и приемник ничего не принимает
источник

m

mAX in Rust Async
но почему не принимает в случае с записью в tx внутри tokio::spawn я не понимаю)
источник

d

diabolo in Rust Async
mAX
а tick 2 как раз потому что 0 прочиталось, 1 записалось в буффур, а после 2 повис цикл на отправке await
тк буффер размером 1 элемент и приемник ничего не принимает
источник

d

diabolo in Rust Async
источник

m

mAX in Rust Async
тоже самое ведь... не тикает
источник

d

diabolo in Rust Async
извини, я с телефона
источник

m

mAX in Rust Async
я проверил, задержка там ничего не дает в плане работы poll_next() poll_peek()

с телефона неудобно! лучше потом) все же интересно разобраться почему так получается
источник

d

diabolo in Rust Async
mAX
тоже самое ведь... не тикает
правильно, тебе надо wake сделать
источник

m

mAX in Rust Async
оу, это что такое?
источник

d

diabolo in Rust Async
mAX
оу, это что такое?
поищи wake_by_ref
источник

d

diabolo in Rust Async
это через контекст делается
источник

m

mAX in Rust Async
Спасибо, гуглю
источник

m

mAX in Rust Async
@hirrolot что я нагуглил! Шикарная дока!)
https://gist.github.com/Hirrolot/b3c8020f42fbcc3986faff82e3d148b7
источник

CM

Chingiz Mamiyev in Rust Async
Его тут нет
источник

CM

Chingiz Mamiyev in Rust Async
+
источник

m

mAX in Rust Async
я в поиске в этой группе его сообщения нашел, да и помню был вроде, год назад что-то подсказывал!)
источник

d

diabolo in Rust Async
mAX
я в поиске в этой группе его сообщения нашел, да и помню был вроде, год назад что-то подсказывал!)
разобрался теперь?
источник

m

mAX in Rust Async
Даа.. работает, но нужно изучаить получше)
сейчас ссделаю минимальный пример работающий)
источник

m

mAX in Rust Async
когда дергаю cx.waker().wake_by_ref(), я так понимаю, запускаю текущий цикл обработки сообщений и он прощелкивает все poll снова
источник