Lib.rs

使用 AsyncWrite 作为 Sink<Item: AsRef<[u8]>.

此适配器生成一个接收器，将传递给它的每个值写入底层写入器。请注意，此函数消耗给定的写入器，返回一个包装版本。

use tokio_into_sink::IntoSinkExt as _;
use futures::{stream, StreamExt as _};
use std::io;

let stream = stream::iter(["hello", "world"]).map(io::Result::Ok);
let write = tokio::fs::File::create("/dev/null").await.unwrap();
let sink = write.into_sink();
stream.forward(sink).await.unwrap();

移植自 futures::io::AsyncWriteExt::into_sink.

lib.rs:

使用 AsyncWrite 作为 Sink<Item: AsRef<[u8]>.

此适配器生成一个接收器，将传递给它的每个值写入底层写入器。请注意，此函数消耗给定的写入器，返回一个包装版本。

use tokio_into_sink::IntoSinkExt as _;
use futures::{stream, StreamExt as _};
use std::io;

let stream = stream::iter(["hello", "world"]).map(io::Result::Ok);
let write = tokio::fs::File::create("/dev/null").await.unwrap();
let sink = write.into_sink();
stream.forward(sink).await.unwrap();

移植自 futures::io::AsyncWriteExt::into_sink.