Телеграмм чат группы rust

А не, я неправа, он замирает на read, когда нет входного стрима

А должен что делать?

Ну, в питоне recv по барабану, есть ли стрим или нет :) В общем, мне нужно чтобы read чекал, есть ли входящий стрим, и если нет, переходил к следующей задаче. Я так понимаю, что AsyncReadExt так не работает. Вопрос, как быть?

Спавнить таску

Ну в плане если сервер, то на каждого клиента спавнить таску

20:07пожаловаться #5

Правда если у тебя сервер, то изначально сокет какой-то не оч правильный

20:08пожаловаться #6

Там надо через bind и accept

20:08пожаловаться #7

Kitsu in Rust Async

Тебе не надо проверять, есть ли что-то читать или нет, за тебя это сделает await

20:08пожаловаться #8

А если клиент, то я хз к какой другой таске надо переходить

https://docs.rs/tokio/1.6.0/tokio/macro.select.html

20:09пожаловаться #9

pl 🦑 hk in Rust Async

docs.rs

select in tokio - Rust

Wait on multiple concurrent branches, returning when the first branch completes, cancelling the remaining branches.

20:11пожаловаться #10

Сложно объяснить, вкратце, клиент передает данные серверу, которые ему поступают через стороннее апи. И клиент не получит входные данные от сервера, пока не перешлет ему таску, взятую с этой апи.

20:18пожаловаться #11

Тогда перед следующим чтением мб скидывать?

20:22пожаловаться #12

Или таски пофиг в каком порядке и их можно одновременно обрабатывать?

20:23пожаловаться #13

Хм, возможно что это то, что мне надо.

20:23пожаловаться #14

Типа, делать запрос к апи до и после чтения входящего стрима? Возможно сработает, но как-то не очень красиво звучит.

20:25пожаловаться #15

Если надо слушать одновременно два потока данных, то select, если нет, то я ничего не понимаю)

20:26пожаловаться #16

if incoming_stream {
get_data;
send_to_api; }
else {
check_api_for_tasks;
send_task_to_server; }
anyway_check_api_for_tasks
send_task_to_server

20:30пожаловаться #17

Да, это наверное подходит под «слушать два потока данных»

20:30пожаловаться #18

В общем, пойду прилаживать select. Отпишусь по результатам. Спасибо, ребята.

A browser interface to the Rust compiler to experiment with the language

20:33пожаловаться #19

2021 May 19

Fortunato in Rust Async

Суть примера: мне нужно использовать future_handler в ветке sleep_future. Почему здесь обязателен pin_mut!() (если его расскомментить, то код компилируется)? JoinHandle ведь сам по себе Unpin
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=263bf087885859ee56e0258fb3532ef4

play.rust-lang.org

Rust Playground