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

групп:

каналов:

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

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

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

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

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

go.backupland.com

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

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

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

Size: a a a

Rust — русскоговорящее сообществo

2034 membersпожаловаться на группу
2020 March 13

MF

Max Frai in Rust — русскоговорящее сообществo
the trait std::future::Future is not implemented for [closure@src/main.rs:125:18: 127:6 preloader_consumer:_]
источник
15:12пожаловаться#1

r

red75prime in Rust — русскоговорящее сообществo
preloader_logic(consumer).await;
Ok(())
источник
15:15пожаловаться#2

A

Anton 📦 ᯌ in Rust — русскоговорящее сообществo
Max Frai
Подскажите, а как правильно делать sleep в асинхронном цикле, который внутри ожидает сообщений от mpsc-продьюсеров?
Tokio::sleep ?
источник
15:15пожаловаться#3

r

red75prime in Rust — русскоговорящее сообществo
main тоже асинхронный
источник
15:15пожаловаться#4

A

Anton 📦 ᯌ in Rust — русскоговорящее сообществo
Anton 📦 ᯌ
Tokio::sleep ?
Он просто будет ждать футуру
источник
15:16пожаловаться#5

MF

Max Frai in Rust — русскоговорящее сообществo
источник
15:16пожаловаться#6

MF

Max Frai in Rust — русскоговорящее сообществo
Но оно меня еще заставило сделать async move и включить async closures
источник
15:17пожаловаться#7

MF

Max Frai in Rust — русскоговорящее сообществo
red75prime
main тоже асинхронный
а если у меня дальше логика должна идти после вызова этой функции, разве мне await не остановит все?
источник
15:17пожаловаться#8

K

Kitsu in Rust — русскоговорящее сообществo
Max Frai
Но оно меня еще заставило сделать async move и включить async closures
|| async move { <body> }
источник
15:18пожаловаться#9

r

red75prime in Rust — русскоговорящее сообществo
Max Frai
а если у меня дальше логика должна идти после вызова этой функции, разве мне await не остановит все?
Да, остановит.  Так что tokio::spawn(preloader_logic(consumer))
источник
15:18пожаловаться#10

MF

Max Frai in Rust — русскоговорящее сообществo
Вот так работает, спасибо
источник
15:19пожаловаться#11

r

red75prime in Rust — русскоговорящее сообществo
preloader_logic() возвращает футуру. Замыкание там не нужно
источник
15:19пожаловаться#12

MF

Max Frai in Rust — русскоговорящее сообществo
Возможно я чего-то не понимаю…
Вот есть у меня:
let (producer, mut consumer) = mpsc::unbounded_channel::<String>();
Я этот producer запихивают в state актикса и в асинхронном обработчике клонирую, чтобы создать нового продьюсера.
let mut producer = state.preloader_producer.clone();
producer.send(data); // <—
источник
15:26пожаловаться#13

MF

Max Frai in Rust — русскоговорящее сообществo
Почему-то в примере у них после send они делают await и все ок, а у меня этот метод синхронный тчо ли. Возвращает Result<(), ..>
источник
15:26пожаловаться#14

MF

Max Frai in Rust — русскоговорящее сообществo
И если так и оставить, то не логгируется в консьюмере, что пришел таск
источник
15:27пожаловаться#15

MF

Max Frai in Rust — русскоговорящее сообществo
источник
15:27пожаловаться#16

r

red75prime in Rust — русскоговорящее сообществo
Какая версия tokio?
источник
15:28пожаловаться#17

MF

Max Frai in Rust — русскоговорящее сообществo
0.2
источник
15:28пожаловаться#18

MF

Max Frai in Rust — русскоговорящее сообществo
tokio = { version = "0.2", features = ["sync"] }
источник
15:28пожаловаться#19

r

red75prime in Rust — русскоговорящее сообществo
Для UnboundedSender send не асинхронный. Должно работать без await. Проблема в чём-то другом
источник
15:30пожаловаться#20