Ребят, кто-то работал из асинков с mio? С неблокирующими TcpStream'ами

Что именно из него? Мы в проекте его и используем. И у него есть свои стримы. Но как это клеить с долгими коннектами, а не коннект-запрос-ответ-закрыл, вот это задача.

0

20.06.2021

Денис

Revertron ⚛
Что именно из него? Мы в проекте его и используем....

> что именно из него готовые async-обёртки для всех примитивов из mio > Но как это клеить с долгими коннектами а в чём, собственно, проблема-то? О_о

0

20.06.2021

Revertron ⚛ Автор вопроса

Денис
> что именно из него готовые async-обёртки для вс...

Ну вот как хранить пучок TcpStream'ов. Как ожидать на них нужные стейты, как в это всунуть TcpListener.accept(), который производит новые стримы, которые !Send, и так далее?

0

20.06.2021

Денис

Revertron ⚛
Ну вот как хранить пучок TcpStream'ов. Как ожидать...

tokio::select! { stream = listener1.accept() => { .. } stream = listener2.accept() => { .. } ... }

0

20.06.2021

Revertron ⚛ Автор вопроса

Денис
tokio::select! { stream = listener1.accept() => ...

Слишком простой пример. Когда пытаешься реально реализовать, тогда натыкаешься на грабли постоянно. Я поэтому и спрашиваю, есть какие-то примеры такого? Кто-то такое реализовывал уже? Кстати, какого типа эти listener1 и listener2 тут должны быть? Кто ими владеет? Захватывает ли их футура? И т.д.

0

20.06.2021

Mikail Bagishov

Revertron ⚛
Слишком простой пример. Когда пытаешься реально ре...

В данном случае это видимо TcpListener-ы, которые штамупют TcpStream-ы

0

20.06.2021

Денис · Accepted Answer

Денис

дык в репозитории mio есть примеры: https://github.com/tokio-rs/mio/tree/master/examples

0

20.06.2021

172 похожих чатов

Ребят, кто-то работал из асинков с mio? С неблокирующими TcpStream'ами

9 ответов

Похожие вопросы