p
по всей видимости да, токио поллит футуру только пару раз. но тут пример для токио 0.1, а у меня 0.2
Size: a a a
2020 March 30
Ct
по всей видимости да, токио поллит футуру только пару раз. но тут пример для токио 0.1, а у меня 0.2
В этом плане вроде ничего не изменилось в 0.2
p
В этом плане вроде ничего не изменилось в 0.2
да, нет функции current()
Ct
да, нет функции current()
Я про общую модель исполнения. Сейчас аналог
notify() через Waker делается.p
Я про общую модель исполнения. Сейчас аналог
notify() через Waker делается.а есть пример?
2020 March 31
Ct
а есть пример?
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=6c6f23e721ce52f7782c7a36c08c4808
Но скорее всего это не то что тебе нужно
Но скорее всего это не то что тебе нужно
p
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=6c6f23e721ce52f7782c7a36c08c4808
Но скорее всего это не то что тебе нужно
Но скорее всего это не то что тебе нужно
ну футура поллится дольше, но все равно она не работает пока внутри не спаникует
UPD: не футура, AsyncRead
UPD: не футура, AsyncRead
Ct
ну футура поллится дольше, но все равно она не работает пока внутри не спаникует
UPD: не футура, AsyncRead
UPD: не футура, AsyncRead
Смотри. Главное правило написания своих футур - возвращать Pending только тогда, когда его underlying футура вернула.
Ct
Если ему следовать то никаких проблем вида "ой моя таска повисла и больше не работает" не должно возникать.
p
Смотри. Главное правило написания своих футур - возвращать Pending только тогда, когда его underlying футура вернула.
мне нужно читать данные из футуры, и помещать их в буффер пока не прочитаю определенное количество байт. Что мне возвращать все это время кроме как не Pending, пока я читаю данные из футуры?
Ct
мне нужно читать данные из футуры, и помещать их в буффер пока не прочитаю определенное количество байт. Что мне возвращать все это время кроме как не Pending, пока я читаю данные из футуры?
Пока ты читаешь данные из футуры ты из poll ничего не возвращаешь вроде
p
Пока ты читаешь данные из футуры ты из poll ничего не возвращаешь вроде
я говорил, у меня AsyncRead
Ct
Если футура заблочилась (вернула Pending) только тогда и возвращай Pending
Ct
я говорил, у меня AsyncRead
Что это меняет?
p
Если футура заблочилась (вернула Pending) только тогда и возвращай Pending
что мне возвращать когда я прочитал данные из футуры, положил их в свой буффер, но не в буффер, который пришел в функцию AsyncRead::poll_read()?
p
мне нужно прочитать N байт данных в буффер внутри футуры, и только потом я могу отдавать данные из футуры
Ct
что мне возвращать когда я прочитал данные из футуры, положил их в свой буффер, но не в буффер, который пришел в функцию AsyncRead::poll_read()?
ничего не возвращать, читай дальше из футуры, пока читается
p
хм, попробую
p
ничего не возвращать, читай дальше из футуры, пока читается
да, спасибо, работает
OA
у меня есть struct X(u8). Я могу как-то сделать ему AsRef<[u8]> и создать слайс &[u8] на его .0?