Структура DuplexStream

Двунаправленный канал для чтения и записи байтов в памяти.

Пара DuplexStream создаётся одновременно; они образуют «канал», который можно использовать как типы ввода-вывода в памяти. Запись в один из пары позволяет прочитать эти данные с другого конца, и наоборот.

Закрытие DuplexStream

Если один конец канала DuplexStream отброшен, все ожидающие чтения на другой стороне продолжат читать данные, пока буфер не опустеет, а затем сообщат о достижении конца файла, вернув 0 байт. Любые записи на другую сторону, включая ожидающие записи (которые ждут освобождения места в буфере), немедленно вернут Err(BrokenPipe).

Пример

let (mut client, mut server) = tokio::io::duplex(64);

client.write_all(b"ping").await?;

let mut buf = [0u8; 4];
server.read_exact(&mut buf).await?;
assert_eq!(&buf, b"ping");

server.write_all(b"pong").await?;

client.read_exact(&mut buf).await?;
assert_eq!(&buf, b"pong");