rust-tokio

0熱

1答えて

tokio_core :: net :: UdpCodec関連タイプの生涯

tokio_core::net::UdpCodecを実装しようとしていますが、これはdns_parser::Packetをdns_parserクレートから作成しています。現在の実装では次のようになります。 pub struct MdnsCodec; impl UdpCodec for MdnsCodec { type In = dns_parser::Packet; typ

rust lifetime mdns rust-tokio 2017-12-27

---

0熱

1答えて

IntoFutureに列挙型をラップしますか？

私は次のコードのようなものをコンパイルしようとしています。私がすべての武器をfutures::future::IntoFutureとしたいと思っていることを理解するのを助ける必要があるようです。それは外側のand_thenがコールバック/クロージャー/デリゲートから期待しているものですから。 今のところ、すべてのアームは最も簡単な列挙型のNothingUseful()でスタブされていますが、最終的

rust rust-tokio 2017-11-13

---

1熱

1答えて

TcpConnectionNewを使用しているとき、 `（）：futures :: Future`という特性が満たされていません

Tokioクレートを使ってRustで単純なTCPクライアントを作成しようとしています。私のコードはthis exampleにかなり近いマイナスTLS： extern crate futures; extern crate tokio_core; extern crate tokio_io; use futures::Future; use tokio_core::net::TcpStre

tcp rust rust-tokio 2017-10-07

---

3熱

1答えて

別のスレッドからhyper :: clientを使用するにはどうしたらいいですか？

私はいくつかの重い操作を実行する複数のスレッドがあり、私は仕事中にクライアントを使用する必要があります。私はHTTPクライアントとしてHyper v0.11を使用していますので、接続を開いたままにするために（keep-aliveモード）同じhyper::Clientを共有する必要があるように、接続を再利用したいと思います。 クライアントはスレッド間で共有できません（SyncまたはSendを実装して

multithreading rust hyper rust-tokio 2017-07-01

---

4熱

1答えて

async（tokio）rust-websocketを使用してクライアント間で可変状態を共有する

rust-websocketとそのTokioベースの非同期システムを使用してRustにwebsocketサーバーを作成しています。しかし、私はクライアント間で可変状態を共有する方法を理解できません。これで let mut core = Core::new().unwrap(); let handle = core.handle(); let server = Server::bind("loc

asynchronous websocket rust rust-tokio 2017-07-03

---

1熱

1答えて

私は<em>ハイパーv0.11</em>で構築されたクライアントでの再試行を実施しようとしているが、私は別の試みのために要求を再利用する方法を見つけることができませんハイパーHTTPクライアント

で再試行実装します #[macro_use] extern crate hyper; extern crate futures; extern crate tokio_core; use futures::Future; use hyper::{Client, Body, Uri, StatusCode}; use hyper::server::{Request, Response

rust hyper rust-tokio 2017-07-05

---

3熱

1答えて

クライアントがtokio-protoサーバーに接続したときにウェルカムメッセージ/バナーを表示するにはどうすればよいですか？

SMTPサーバーは、クライアントがコマンドの送信を開始するための信号である接続確立時にウェルカムメッセージを表示する必要があります（220サービス準備完了）。これはtokio-protoの要求 - 応答のパラダイムと矛盾しているようです。 私は、サーバーが要求とクライアントの応答（非推奨のTURN）を送信するなど、完全に逆転している可能性がありますが、現時点では接続時のウェルカムメッセージ、つまり

tcp rust rust-tokio 2017-10-19

---

1熱

1答えて

Iron :: Hyper :: clientとtokio_coreをIronとHyperで再利用

Ironハンドラの内部でクライアントのリクエストを行います。 TokioのCoreとHyperのClientを再利用するにはどうすればよいですか？私はハイパー0.11.0とトキオコア0.1を使用しています。 fn get_result(req: &mut Request) -> IronResult<Response> { let mut payload = String::new();

rust hyper rust-tokio 2017-07-14

---

1熱

1答えて

Rustでtokio_protoとtokio_serviceを使ってメッセージをストリーミングする方法

私のSmtpServiceで、処理が完了したらすぐにレスポンスヘッダーと本文を送信したいと思います。これは、SMTP交換に従ってください： C: DATA S: 354 Start mail input C: ... data ... C: ... more ... C: . S: 250 Ok 私はplaygroundでこれだけを持っている： #[macro_use] exter

request rust streaming response rust-tokio 2017-10-23

---

1熱

1答えて

Rustでhyper、tokio、futureを使ってHTTPリクエストのタイムアウトを設定するにはどうすればよいですか？

非同期Hyper（> = 0.11）を使用してHTTP要求のタイムアウトを設定するにはどうすればよいですか？ここで はタイムアウトなしのコードの例です： extern crate hyper; extern crate tokio_core; extern crate futures; use futures::Future; use hyper::Client; use tokio_

http rust timeout hyper rust-tokio 2017-07-25

---