rust-tokio

2열

2답변

녹에서 미래와 스트림을 선택하는 방법은 무엇입니까?

나는 녹에서 선물/tokio를 실험하기 시작했습니다. 나는 단지 미래를 가지고, 또는 단지 물줄기로 정말로 기본적인 것들을 할 수 있습니다. 미래와 스트림을 어떻게 선택할 수 있는지 궁금합니다. tokio 설명서에서 장난감 문제를 연장하여 tokio_timer::Timer을 사용하여 시간 초과 된 HTTPS 요청을 수행하려면 어떻게해야합니까? extern

stream rust future rust-tokio 2017-03-21

---

1열

1답변

특성 바운드`() : futures :: Future`가 TcpConnectionNew를 사용할 때 만족하지 않습니다

Tokio 크레이트를 사용하여 녹에서 간단한 TCP 클라이언트를 작성하려고합니다. 내 코드 this example 뺀 TLS 꽤 가까이 : extern crate futures; extern crate tokio_core; extern crate tokio_io; use futures::Future; use tokio_core::net::TcpSt

tcp rust rust-tokio 2017-10-07

---

-2열

1답변

토키오 컬 : 로컬`Vec`에 캡처 출력 - <p></p> 사용하여 벡터로 다운로드 한 데이터를 수집하는 중 ... 나는 아직 수명 및 폐쇄를 이해하기 충분히 녹 모르는 값

을 빌려 오래 살 수있다 토키오 컬 : extern crate curl; extern crate futures; extern crate tokio_core; extern crate tokio_curl; use std::io::{self, Write}; use std::str; use curl::easy::Easy; use tokio_core

rust rust-tokio 2016-09-13

---

3열

1답변

클라이언트가 tokio-proto 서버에 연결할 때 환영 메시지/배너를 표시하는 방법은 무엇입니까?

SMTP 서버는 클라이언트가 명령을 보내기 시작하기위한 신호 인 연결을 설정하면 환영 메시지를 표시해야합니다 (220 서비스 준비 완료). 이것은 tokio-proto의 요청 - 응답 패러다임과 충돌하는 것으로 보인다. 나는 서버가 요청과 클라이언트 응답 (폐기 된 TURN)을 보내는 것과 같이 완전히 뒤집을 수 있다고 상상할 수 있지만, 지금은 연결시 환

tcp rust rust-tokio 2017-10-19

---

1열

1답변

녹이에서 tokio_proto 및 tokio_service를 사용하여 메시지를 스트리밍하는 방법

내 SmtpService에 처리가 완료되면 즉시 응답 헤더를 보내고 싶습니다. C: DATA S: 354 Start mail input C: ... data ... C: ... more ... C: . S: 250 Ok 내가 playground이 많이있어 : 이것은 SMTP 교환을 따라야 그것도 가능 또는 내가 대신 두 개의 메시지를 생성해야하

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

---

-1열

1답변

개행 문자를 보내고 있는데도 TCP 에코 서버가 응답하지 않습니다.

마지막에 개행 문자가있는 응답을 보내는 에코 서버와 통신하는 클라이언트를 작성하기 위해 Tokio 클라이언트 자습서를 따르려고합니다. 여기에 내가 무엇을 가지고 :이 "A \ n을"을 인쇄 할 것으로 예상하고 extern crate futures; extern crate tokio_core; extern crate tokio_io; use std::

rust rust-tokio 2017-12-20

---

2열

1답변

Rust Tokio 작업에서 무기한으로 무제한으로 읽는 방법?

나는 .for_each()이 트릭을한다고 가정하지만 채널에서 첫 번째 (미래) 항목 만 반환 한 다음 채널이 비어 있으면 반환합니다. .for_each()이 아닌 Tokio/future 컨텍스트에서 수행 할 작업에서 무한정 채널을 읽는 방법은 무엇입니까? let tx_origs_reader = rx_chan.for_each(move |tx_orig| {

rust channel rust-tokio 2017-04-18

---