Вопросы с тегом 'rust-tokio'

Количество результатов: 26

3 голоса
2 ответа
Как я могу использовать оператор со знаком вопроса на ошибки ручки фьючерсной Tokio?

У меня есть клиент обработки; Future что делает некоторые вещи. Можно ли использовать impl Future<Item = (), Error = io::Error> как тип возвращаемого значения и ...

3 голоса
1 ответ
Как использовать асинхронный/Await синтаксиса с Токио?

Я пытаюсь использовать асинхра/с процессами ждут в Русте. я использую tokio а также tokio-process: #![feature(await_macro, async_await, futures_api)] extern crate to...

0 голосов
1 ответ
Будущее Tokio, которая считывает данные из канала и использует poll_fn и try_ready никогда не завершается

У меня есть будущее Tokio, которая никогда не заканчивает (rx это Receiver а также sock это Tokio UdpSocket). Это в основном читает пакеты из очереди пакетов и передае...

2 голоса
1 ответ
Как добавлять задачи в цикл обработки событий Tokio, который работает в другом потоке?

я бы хотел раскрутить цикл событий Tokio вместе с сервером Rocket, а затем добавлять события в этом цикле позже. Я читаю Есть ли способ запустить Tokio :: Задержка в н...

1 голос
1 ответ
Альтернатива клонирования отправителя TOKIO канала для закрытия фьючерсного

Я работаю с tokio а также hyper нереститься несколько задач. // Defining the task let task = self.some_future_using .map(move |resp| println!("OK: {}", re...

2 голоса
1 ответ
Может ли задача Tokio завершить все время работы корректно?

Пускаю среды выполнения Tokio с кодом, как это: tokio::run(my_future); Мое будущее продолжается начать кучу задач в ответ на различные условия. Одна из этих задач ...

4 голоса
1 ответ
Почему вызова результат Tokio :: икру в панике «SpawnError {is_shutdown: истинно}»?

Я хочу использовать Delay чтобы сделать некоторую работу позже. Если я использую tokio::run, Это просто отлично работает, но паникует при использовании tokio::spawn: ...

0 голосов
1 ответ
Использование обратного вызова при обработке TCP соединений с Tokio

Я пытаюсь иметь структуру, которая начинает цикл обработки событий, прослушивает TCP соединений и вызывает функцию обратного вызова для каждого соединения. (Обратный...

0 голосов
1 ответ
Есть ли способ запустить Tokio :: Задержка в новом потоке, чтобы позволить основной цикл продолжать?

Я пытаюсь запустить функцию в конце задержки, если таймер не будет отменен. Прецедент является нажать и удерживать/двойное нажатие для ввода данных пользователя. Осно...

3 голоса
2 ответа
Tokio-асинхронному ждут с чертой

Я хотел бы написать функции асинхронных в черте, но так как async fn в чертах пока не поддерживаются, я пытаюсь найти эквивалентный интерфейс метода. Это то, что я пыт...

2 голоса
1 ответ
Hyper-сервер падает соединение на возвращении Async :: NotReady в будущем

Я пытаюсь запустить гипер сервер с асинхронным ответ на запрос с использованием будущего. Когда будущегокиевстар poll метод вызывается и возвращает Async::NotReady, Со...

-1 голос
1 ответ
Соответствие будущим типам

Я пытаюсь работать с фьючерсами, чтобы искать асинхронно искать значение. Если это значение существует, я хочу его вернуть, а если его нет, я хочу его создать. // A n...

1 голос
2 ответа
Как запланировать повторяющуюся задачу в Токио?

Я замена синхронного сокета кода, написанный на Русте с асинхронным эквивалентом с использованием Tokio. Tokio использует фьючерсы на асинхронную активность, так задач...

3 голоса
1 ответ
Как читать выходной подпроцесс асинхронно

Я хочу, чтобы реализовать futures::Stream для чтения и разбора стандартного вывода дочернего подпроцесса. То, что я делаю в данный момент: икра подпроцесс и получит...

4 голоса
3 ответа
Как отменить бесконечный поток внутри самого потока?

Я стараюсь, чтобы отменить интервал (interval_timer) После опорожнения очереди, но не уверен, что это правильная стратегия. let mut some_vars = vec![1, 2, 3, 4, 5, 6,...

3 голоса
1 ответ
Получение нескольких URL-адресов одновременно с Hyper

Я пытаюсь адаптировать Hyper простой пример клиент чтобы получить несколько URL-адресов одновременно. Это код, который я в настоящее время: extern crate futures; ext...

-1 голос
1 ответ
Tokio эхо сервер. Не могу читать и писать в то же время

Я пытаюсь построить эхо-сервер в Токио. Я видел примеры, но все они, кажется, используют io::copy от Tokio IO, которые я не могу использовать, потому что я хочу, чтобы...

0 голосов
1 ответ
Полное будущее, если определенное состояние происходит

Я хотел бы создать будущее, которое завершает, если определенное значение принимается по протоколу UDP соединения. Для уточнения, предположим, я отправить пинг с иден...

1 голос
2 ответа
Асинхронный читать UdpSocket

Я пытаюсь одновременно обрабатывать прибывающих UDP пакетов в Токио. Однако следующий MWE не делать то, что я ожидал: extern crate futures; extern crate tokio_core; e...

0 голосов
1 ответ
Как бы я сделать запрос на TcpClient за единицу в фьючерсном поток?

У меня есть концептуальный проект, в котором клиент отправляет серверу номер (PrimeClientRequest), Сервер вычисляет, если значение является простым или нет, и возвраща...

3 голоса
2 ответа
Deserialize из Tokio розетки

Я использую Tokio реализовать сервер, который взаимодействует с сообщениями сериализовать с serde (bincode). Без асинхронных и фьючерсов я хотел бы сделать extern cra...

3 голоса
1 ответ
Почему не сбросив этот SpawnHandle отменить свое будущее?

Вот пример программы: extern crate futures; extern crate tokio_core; use futures::{Async, Future, Stream}; use tokio_core::reactor::Core; use tokio_core::net::TcpLis...

3 голоса
2 ответа
Можно ли закрыть TcpListener в Токио?

у меня есть tokio_core::net::TcpListener что я создаю, а затем вызвать incoming способ дальше, чтобы получить поток входящих соединений. Я затем использовать for_each ...

7 голосов
1 ответ
Повторение задачи ржавчины с tokio_timer

Я создаю повторяющуюся задачу в Русте, используя каркас Tokio. Следующий код основан на запрос завершен изменение чтобы добавить эту функцию к обрешетке Tokio таймера....

3 голоса
1 ответ
Как достичь нулевой копии в tokio_core :: IO :: CoDeC :: декодировании (...)?

Моя цель реализовать Codec который истощает при условии, EasyBuf к границам сообщения и декодирует его в структуры, которые просто ссылаются на содержимое для предотвр...

21 голос
1 ответ
Асинхронный повторное подключение клиента к серверу в бесконечном цикле

Я не в состоянии создать клиент, который пытается подключиться к серверу, а также: если сервер выключен он должен попробовать еще раз в бесконечном цикле если серве...