Структура SimplexStream

pub struct SimplexStream { /* private fields */ }

Доступно только при включённой функции крейта io-util.

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

Его можно создать с помощью функции simplex, которая создаёт пару — читатель и писатель, или вызвав SimplexStream::new_unsplit, которая создаёт дескриптор для чтения и записи.

Пример

let (mut receiver, mut sender) = tokio::io::simplex(64);

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

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

Реализации

impl SimplexStream

pub fn new_unsplit(max_buf_size: usize) -> SimplexStream

Создаёт однонаправленный буфер, который работает как канал в памяти. Чтобы создать разделённую версию с отдельными читателем и писателем, можно воспользоваться функцией simplex.

Аргумент max_buf_size задаёт максимальное количество байтов, которое можно записать в буфер, прежде чем он вернёт Poll::Pending.

Реализации трейтов

impl AsyncRead for SimplexStream

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Пытается прочитать данные из AsyncRead в buf. Подробнее

impl AsyncWrite for SimplexStream

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Пытается записать байты из buf в объект. Подробнее

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Как и poll_write, но записывает данные из среза буферов. Подробнее

fn is_write_vectored(&self) -> bool

Определяет, реализует ли этот объект записи эффективный метод poll_write_vectored. Подробнее

fn poll_flush(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<()>>

Пытается сбросить данные объекта, гарантируя, что все буферизованные данные достигнут места назначения. Подробнее

fn poll_shutdown(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<()>>

Инициирует или пытается завершить работу этого объекта записи; возвращает успех, когда соединение ввода-вывода полностью закрыто. Подробнее

impl Debug for SimplexStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Форматирует значение с помощью заданного форматтера. Подробнее

Автоматические реализации трейтов

impl Freeze for SimplexStream

impl RefUnwindSafe for SimplexStream

impl Send for SimplexStream

impl Sync for SimplexStream

impl Unpin for SimplexStream

impl UnsafeUnpin for SimplexStream

impl UnwindSafe for SimplexStream

Обобщённые реализации

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Получает TypeId для self. Подробнее

impl<R> AsyncReadExt for R
where R: AsyncRead + ?Sized,

fn chain<R>(self, next: R) -> Chain<Self, R>
where Self: Sized, R: AsyncRead,

Доступно только при включённой функции crate io-util.

Создаёт новый экземпляр AsyncRead, объединяющий этот поток с next. Подробнее

fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> Read<'a, Self>
where Self: Unpin,

Доступно только при включённой функции crate io-util.

Извлекает несколько байтов из этого источника в указанный буфер и возвращает количество прочитанных байтов. Подробнее

fn read_buf<'a, B>(&'a mut self, buf: &'a mut B) -> ReadBuf<'a, Self, B>
where Self: Unpin, B: BufMut + ?Sized,

Доступно только при включённой функции crate io-util.

Извлекает несколько байтов из этого источника в указанный буфер, продвигая внутренний курсор буфера. Подробнее

fn read_exact<'a>(&'a mut self, buf: &'a mut [u8]) -> ReadExact<'a, Self>
where Self: Unpin,

Доступно только при включённой функции crate io-util.

Считывает ровно столько байтов, сколько требуется для заполнения buf. Подробнее

fn read_u8(&mut self) -> ReadU8<&mut Self>
where Self: Unpin,

Доступно только при включённой функции crate io-util.

Считывает из нижележащего средства чтения беззнаковое 8-битное целое число. Подробнее

fn read_i8(&mut self) -> ReadI8<&mut Self>
where Self: Unpin,

Доступно только при включённой функции crate io-util.

Считывает из нижележащего средства чтения знаковое 8-битное целое число. Подробнее

fn read_u16(&mut self) -> ReadU16<&mut Self>
where Self: Unpin,

Доступно только при включённой функции crate io-util.

Считывает из нижележащего средства чтения беззнаковое 16-битное целое число в порядке байтов от старшего к младшему. Подробнее

fn read_i16(&mut self) -> ReadI16<&mut Self>
where Self: Unpin,

Доступно только при включённой функции crate io-util.

Считывает из нижележащего средства чтения знаковое 16-битное целое число в порядке байтов от старшего к младшему. Подробнее

fn read_u32(&mut self) -> ReadU32<&mut Self>
where Self: Unpin,

Доступно только при включённой функции crate io-util.

Считывает из нижележащего средства чтения беззнаковое 32-битное целое число в порядке байтов от старшего к младшему. Подробнее