์ทจ์
future๊ฐ ๋๋ฝ๋๋ฉด ๋ค์ ํด๋งํ ์ ์๋ค๋ ์๋ฏธ์
๋๋ค. ์ด๋ฅผ _์ทจ์_๋ผ๊ณ ํ๋ฉฐ, await
์ง์ ์์ ๋ฐ์ํ ์ ์์ต๋๋ค. future๊ฐ ์ทจ์๋๋๋ผ๋ ์์คํ
์ด ์ฌ๋ฐ๋ฅด๊ฒ ์๋ํ ์ ์๋๋ก ์ฃผ์๋ฅผ ๊ธฐ์ธ์ฌ์ผ ํฉ๋๋ค. ์๋ฅผ ๋ค์ด ๊ต์ฐฉ ์ํ๊ฐ ๋๊ฑฐ๋ ๋ฐ์ดํฐ๊ฐ ์์ค๋๋ฉด ์ ๋ฉ๋๋ค.
use std::io::{self, ErrorKind}; use std::time::Duration; use tokio::io::{AsyncReadExt, AsyncWriteExt, DuplexStream}; struct LinesReader { stream: DuplexStream, } impl LinesReader { fn new(stream: DuplexStream) -> Self { Self { stream } } async fn next(&mut self) -> io::Result<Option<String>> { let mut bytes = Vec::new(); let mut buf = [0]; while self.stream.read(&mut buf[..]).await? != 0 { bytes.push(buf[0]); if buf[0] == b'\n' { break; } } if bytes.is_empty() { return Ok(None); } let s = String::from_utf8(bytes) .map_err(|_| io::Error::new(ErrorKind::InvalidData, "not UTF-8"))?; Ok(Some(s)) } } async fn slow_copy(source: String, mut dest: DuplexStream) -> std::io::Result<()> { for b in source.bytes() { dest.write_u8(b).await?; tokio::time::sleep(Duration::from_millis(10)).await } Ok(()) } #[tokio::main] async fn main() -> std::io::Result<()> { let (client, server) = tokio::io::duplex(5); let handle = tokio::spawn(slow_copy("hi\nthere\n".to_owned(), client)); let mut lines = LinesReader::new(server); let mut interval = tokio::time::interval(Duration::from_millis(60)); loop { tokio::select! { _ = interval.tick() => println!("ํฑ!"), line = lines.next() => if let Some(l) = line? { print!("{}", l) } else { break }, } } handle.await.unwrap()?; Ok(()) }
-
์ปดํ์ผ๋ฌ๋ ์ทจ์ ์์ ์ ๋์์ด ๋์ง ์์ต๋๋ค. API ๋ฌธ์๋ฅผ ์ฝ๊ณ
async fn
์ ์ํ๋ฅผ ๊ณ ๋ คํด์ผ ํฉ๋๋ค. -
panic
๋ฐ?
์ ๋ฌ๋ฆฌ ์ทจ์๋ ์ค๋ฅ ์ฒ๋ฆฌ๊ฐ ์๋ ์ผ๋ฐ์ ์ธ ์ ์ด ํ๋ฆ์ ์ผ๋ถ์ ๋๋ค. -
์ด ์์์๋ ๋ฌธ์์ด์ ์ผ๋ถ๊ฐ ์์ค๋ฉ๋๋ค.
-
tick()
๋ธ๋์น๊ฐ ๋จผ์ ์๋ฃ๋ ๋๋ง๋คnext()
๋ฐbuf
๊ฐ ์ญ์ ๋ฉ๋๋ค. -
๋ค์๊ณผ ๊ฐ์ด
buf
๋ฅผ ๊ตฌ์กฐ์ฒด์ ์ผ๋ถ๋ก ๋ง๋ค์ดLinesReader
๊ฐ ์ทจ์๋์ง ์๋๋ก ํ ์ ์์ต๋๋ค.#![allow(unused)] fn main() { struct LinesReader { stream: DuplexStream, bytes: Vec<u8>, buf: [u8; 1], } impl LinesReader { fn new(stream: DuplexStream) -> Self { Self { stream, bytes: Vec::new(), buf: [0] } } async fn next(&mut self) -> io::Result<Option<String>> { // buf ๋ฐ bytes ์ ๋์ฌ๋ฅผ self๋ก ์ง์ ํฉ๋๋ค. // ... let raw = std::mem::take(&mut self.bytes); let s = String::from_utf8(raw) // ... } } }
-
-
Interval::tick
์ ํฑ์ด โdeliveredโ ๋๋์ง ์ถ์ ํ๋ฏ๋ก ์ทจ์์ ์์ ํฉ๋๋ค. -
AsyncReadExt::read
๋ ๋ฐ์ดํฐ๋ฅผ ๋ฐํํ๊ฑฐ๋ ์ฝ์ง ์์ผ๋ฏ๋ก ์ทจ์์ ์์ ํฉ๋๋ค. -
AsyncBufReadExt::read_line
์ ์์ ์ ์ฌํ๋ฉฐ ์ทจ์์ ์์ ํ์ง ์์ต๋๋ค. ์์ธํ ๋ด์ฉ๊ณผ ๋์์ ๊ด๋ จ ๋ฌธ์๋ฅผ ์ฐธ๊ณ ํ์ธ์.