E
если правильно понимаю, trait Stream был скопирован в std из futures-core ?
Size: a a a
2021 March 10
С
ещё вопрос: можно ли уже использовать https://doc.rust-lang.org/nightly/std/stream/index.html
Как ты видишь по ссылке, он ещё в найтли. Можно пойти посмотреть в issue, какие проблемы остались нерешёнными. Если тебе ок в найтли и проблемы из issue тебя не затрагивают, то почему нет
E
Как ты видишь по ссылке, он ещё в найтли. Можно пойти посмотреть в issue, какие проблемы остались нерешёнными. Если тебе ок в найтли и проблемы из issue тебя не затрагивают, то почему нет
есть сомнения в том, что этот trait Stream из std могут убрать или изменить, перенести
D
есть сомнения в том, что этот trait Stream из std могут убрать или изменить, перенести
Вряд ли, но могут
D
Ну и это фактически не тот же тип, что и в существующих библиотеках, хоть и имеет такой же интерфейс
D
Так что не очень понятно, как его можно использовать сейчас
E
а во fututres-core не будет меняться trait Stream ?
или может измениться?
или может измениться?
С
Так что не очень понятно, как его можно использовать сейчас
Лично я дождался бы стабилизации и использовал бы тип из tokio-stream или futures. Когда стабилизация произойдёт, futures и токио достаточно быстро должны перейти на трейт из std, как они сделали с Future.
E
а tokio-stream - это разве не временный crate ?
E
из tokio-stream ничего не будут в std переносить?
D
Лично я дождался бы стабилизации и использовал бы тип из tokio-stream или futures. Когда стабилизация произойдёт, futures и токио достаточно быстро должны перейти на трейт из std, как они сделали с Future.
Полностью поддерживаю
D
а во fututres-core не будет меняться trait Stream ?
или может измениться?
или может измениться?
Он точно изменится; когда стабилизируют трейт в стд, futures будет его реэкспортировать
E
понятно, спасибо
2021 March 15
m
Товарищи, подскажите пожалуйста!
Хочу в своем кастомном стриме дернуть waker через какой-то интервал.. кроме как запустить дополнительный поток и из него дергать нету после sleep() нету решения удобного?
Хочу в своем кастомном стриме дернуть waker через какой-то интервал.. кроме как запустить дополнительный поток и из него дергать нету после sleep() нету решения удобного?
DF
Добавляешь таймер в реактор , передаешь вейкер свой этому таймеру , чтобы он дёрнул для тебя
DF
Всегда же вейкер в таких случаях надо дальше передавать
m
Сделали бы какой-нибудь метод типа
а то получается что-то городить нужно дополнительно для простой задачи
wake(), но с задержкойа то получается что-то городить нужно дополнительно для простой задачи
MB
Сделали бы какой-нибудь метод типа
а то получается что-то городить нужно дополнительно для простой задачи
wake(), но с задержкойа то получается что-то городить нужно дополнительно для простой задачи
То есть экзекутор должен тянуть за собой реализацию таймера? Это противоречит дизайну футур, который четко разграничивает исполнение футур и их пробуждения.
m
Да, согласен, но как-то неудобно)
MB
Ну и кстати я вот не могу сходу придумать кейс, когда вейкер точно знает, что пробудить футуру надо через такой-то промежуток, и ты при этом не пишешь собственый таймер :)