tokioの非同期IO

tokioで非同期的にread可能なものはtokio::io::AsyncRead traitを実装している

これは poll_read というメソッドを持っていて、読み取り可能(OK)か、Pendingかなどの情報が返ってくる

とはいえ、直接これを呼ぶことはほぼなくて、基本AsyncReadExt拡張メソッドを使う

AsyncReadExtをuseすると、read が生えて、返り値はawaitできる

code:_.rs

use tokio::io;

use tokio::io::{AsyncRead, AsyncReadExt, repeat};

async fn main() -> io::Result<()> {

let mut buf = 0; 10;

let read = repeat(0xFF).read(&mut buf).await?;

println!("{:?}", buf);

Ok(())

}

読み取りバッファーの管理

読み取ったデータを一時的に格納しておく領域が欲しいが、

tcpのようなストリーム指向の場合、readできれいに1フレーム分読み取れる保証はない

よって途中までは読みつつ、もう一度readして続きのデータが欲しいといったケースがある

そういう場合はtokio_util::codec::Framedを使う