PL
Но я не шарю в виндовом IO, так что могу ошибаться
Size: a a a
2021 July 20
DF
Iocp работает с overlapped структурами ж
DF
Вот етот тезис откудова?
PL
User APC это фактически и есть aio колбеки.
PL
Но я сейчас посмотрел, что это лишь один из способов ожидания и что альтернатива (более каноничная?) таки iocp
DF
Да
DF
Вот ето
2021 July 21
MB
Готово
2021 July 24
FS
Привет! Я тут пытаюсь написать адаптер для futures::Stream. Как можно подписаться на вейки этого стрима?
FS
пробема x: у меня есть стрим векторов произвольного размера и я в этом адаптере их переупаковываю в вектора одинакого размера
FS
И когда приходит вектор, слишком маленький для того, чтобы набрать на полный пакет я возвращаю Poll::Pending из фьючи, и она больше не поллится
П
Гугли в сторону вейкеров
MB
Если у тебя адаптер стрима, то тебе надо так или иначе полльнуть этот стрим, чтобы он тебя вейкал
FS
ааа я поллю его с тем же контекстом, который приходит в этот poll_next, значит теоретически он должен мой стрим тоже подписывать
MB
FS
хм значит наверное проблема в другом, буду втыкать дальше, спасибо
MB
Если вложенный стрим работает правильно, то это наверное значит что ты в какой-то ситуации получил от него Poll::Ready, а сам вернул Poll::Pending
FS
так и было. оно должно заполлиться когда следующий вейк случается.
Этого не происходит возможно потому что я в тесте делаю два сенда подряд, а вейк наверное только один происходит
Этого не происходит возможно потому что я в тесте делаю два сенда подряд, а вейк наверное только один происходит
MB
https://gist.github.com/rust-play/6977063f2070dfd66476dbd936c9e13a#file-playground-rs-L46
Ну да, вот тут ошибка.
Вложенный стрим вернул Poll::Ready. Это значит, что он со своей стороны сделал все, что от него просили. Обязанность вейкать возникает только тогда, когда стрим или футура возвращают Poll::Pending
Ну да, вот тут ошибка.
Вложенный стрим вернул Poll::Ready. Это значит, что он со своей стороны сделал все, что от него просили. Обязанность вейкать возникает только тогда, когда стрим или футура возвращают Poll::Pending