В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

Rust Async

476 membersпожаловаться на группу
2021 February 01

MB

Mikail Bagishov in Rust Async
Eugene
получается, что лучше минимизировать зависимость от tokio-stream?
Ну лично я не вижу проблем в том, чтобы им пользоваться.

Даже когда выйдет версия токио со встроенной поддержкой стримов, в тыкву tokio-stream не превратится.
источник
22:36пожаловаться#1

MB

Mikail Bagishov in Rust Async
Eugene
а что будет с tokio_stream::StreamExt ?
полагаю, его вернут в tokio, как это и было раньше.
источник
22:37пожаловаться#2

E

Eugene in Rust Async
а зачем тогда в tokio-stream вынесли?
источник
22:37пожаловаться#3

MB

Mikail Bagishov in Rust Async
Eugene
а зачем тогда в tokio-stream вынесли?
Потому что semver
источник
22:37пожаловаться#4

MB

Mikail Bagishov in Rust Async
трейт Stream - это публичная зависимость.
источник
22:38пожаловаться#5

MB

Mikail Bagishov in Rust Async
Значит, выпуск futures 0.4 не позволил бы tokio перейти на них
источник
22:38пожаловаться#6

MB

Mikail Bagishov in Rust Async
Ну то есть общий принцип такой, что если зависимость публичная (то есть ее кусочки видны в API твоей библиотеки), и ты меняешь ее версию на несовместимую, то это breaking change.
источник
22:39пожаловаться#7

MB

Mikail Bagishov in Rust Async
По той же причине tokio 0.2 был вынужден сидеть на старом mio - он был выиден в API, и обновится с 0.6 на 0.7 было нельзя.
источник
22:39пожаловаться#8

E

Eugene in Rust Async
а зачем trait Stream планируют добавить в std?
источник
22:39пожаловаться#9

MB

Mikail Bagishov in Rust Async
Потому что это важный для асинхронщины трейт, асинхроннйы аналог итераторов.
источник
22:40пожаловаться#10

MB

Mikail Bagishov in Rust Async
То есть примерно та же мотивация, что и с футурами.
источник
22:40пожаловаться#11

E

Eugene in Rust Async
понятно, спасибо
источник
22:40пожаловаться#12
2021 February 02

AV

A V in Rust Async
Eugene
trait Stream ведь во futures-core находится
futures - это futures
источник
12:53пожаловаться#13

AV

A V in Rust Async
этот крейт рангом идентичен tokio
источник
12:53пожаловаться#14

IL

Ilya Lakhin in Rust Async
Привет! А как из Future сделать другую Future, которая будет возвращать Some(T)?
источник
13:20пожаловаться#15

P

Pavel in Rust Async
@eliah_lakhin Может быть можно через 
and_then(|v| async { Some(v) })
источник
13:23пожаловаться#16

RP

Roman Proskuryakov in Rust Async
Ilya Lakhin
Привет! А как из Future сделать другую Future, которая будет возвращать Some(T)?
future.map(Some)
источник
13:24пожаловаться#17

IL

Ilya Lakhin in Rust Async
ок, задача на самом деле несколько иная. Прошу прощения, что сразу не сформулироввал.

Есть Send + 'static функция, которая возвращает Send + 'static Future. Мне нужно эту функцию локально "обернуть" так, чтобы вначала она проверяла некое условие через ссылку на локальную переменную и в случае провала возвращала None, а в случае успеха выполняла исходную функцию и возвращала Some(T) от результата этой функции.

Примерно нечто вроде такого:

finish_flag = .. //это локальная переменная

let checked_iteration = move |reference: TaskReference| async move {
    if finish_flag.get().is_some() {
         return None;
    }

    Some(iteration(reference).await)
};
источник
13:29пожаловаться#18

IL

Ilya Lakhin in Rust Async
Там какая-то сложная ошибка смысл которой я не вполне понял, но кажется ему не нравится, что iteration не Sync
источник
13:31пожаловаться#19

IL

Ilya Lakhin in Rust Async
iteration - исходная функция
источник
13:31пожаловаться#20