Структура OwnedWriteHalf

pub struct OwnedWriteHalf { /* private fields */ }

Доступно только на Unix и при включённой возможности crate net.

Владеющая половина для записи из UnixStream, созданная с помощью into_split.

Обратите внимание, что в реализации AsyncWrite для этого типа вызов poll_shutdown завершит работу потока в направлении записи. Удаление половины для записи также завершит работу половины потока для записи.

Запись в OwnedWriteHalf обычно выполняется с помощью вспомогательных методов, предоставляемых трейтом AsyncWriteExt.

Реализации

impl OwnedWriteHalf

pub fn reunite(self, other: OwnedReadHalf) -> Result<UnixStream, ReuniteError>

Пытается объединить две половины UnixStream и восстановить исходный сокет. Операция завершается успешно, только если обе половины были получены в результате одного вызова into_split.

pub fn forget(self)

Уничтожает половину для записи, но не закрывает её до тех пор, пока не будет уничтожена половина для чтения. Если половина для чтения уже уничтожена, поток закрывается.

pub async fn ready(&self, interest: Interest) -> Result<Ready>

Ожидает наступления любого из запрошенных состояний готовности.

Эта функция обычно используется в паре с try_write(). Её можно использовать вместо writable(), чтобы проверить, содержит ли возвращённый набор готовности события Ready::WRITABLE и Ready::WRITE_CLOSED.

Функция может завершиться, даже если сокет не готов. Это ложноположительный результат, и попытка выполнить операцию вернёт io::ErrorKind::WouldBlock. Функция также может вернуть пустой набор Ready, поэтому всегда проверяйте возвращённое значение и, возможно, снова ожидайте, если запрошенные состояния не установлены.

Эта функция эквивалентна UnixStream::ready.

Безопасность отмены

Этот метод безопасен при отмене. После наступления события готовности метод продолжит немедленно возвращать результат, пока событие готовности не будет обработано попыткой чтения или записи, завершившейся с WouldBlock или Poll::Pending.

pub async fn writable(&self) -> Result<()>

Ожидает, пока сокет не будет готов к записи.

Эта функция эквивалентна ready(Interest::WRITABLE) и обычно используется в паре с try_write().

Безопасность отмены

Этот метод безопасен при отмене. После наступления события готовности метод продолжит немедленно возвращать результат, пока событие готовности не будет обработано попыткой записи, завершившейся с WouldBlock или Poll::Pending.

pub fn try_write(&self, buf: &[u8]) -> Result<usize>

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

Функция попытается записать всё содержимое buf, но может быть записана только часть буфера.

Эта функция обычно используется в паре с writable().

Возвращаемое значение

Если данные успешно записаны, возвращается Ok(n), где n — количество записанных байтов. Если поток не готов к записи данных, возвращается Err(io::ErrorKind::WouldBlock).

pub fn try_write_vectored(&self, buf: &[IoSlice<'_>]) -> Result<usize>

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

Данные записываются из каждого буфера по порядку; при этом последний читаемый буфер может быть обработан лишь частично. Этот метод эквивалентен одному вызову try_write() с объединёнными буферами.

Эта функция обычно используется в паре с writable().

Возвращаемое значение

pub fn peer_addr(&self) -> Result<SocketAddr>

Возвращает адрес сокета удалённой стороны этого соединения.

pub fn local_addr(&self) -> Result<SocketAddr>

Возвращает адрес сокета локальной стороны этого соединения.

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

impl AsRef<UnixStream> for OwnedWriteHalf

fn as_ref(&self) -> &UnixStream

Преобразует этот тип в общую ссылку на входной тип (обычно выводимый).

impl AsyncWrite for OwnedWriteHalf

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>>

Как и 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 OwnedWriteHalf

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

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

impl Drop for OwnedWriteHalf

fn drop(&mut self)

Выполняет деструктор этого типа. Подробнее

fn pin_drop(self: Pin<&mut Self>)

🔬Это экспериментальный API, доступный только в nightly-версии. (pin_ergonomics)

Выполняет деструктор этого типа, но, в отличие от Drop::drop, требует, чтобы self был закреплён. Подробнее

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

impl Freeze for OwnedWriteHalf

impl RefUnwindSafe for OwnedWriteHalf

impl Send for OwnedWriteHalf

impl Sync for OwnedWriteHalf

impl Unpin for OwnedWriteHalf

impl UnsafeUnpin for OwnedWriteHalf

impl UnwindSafe for OwnedWriteHalf

Общие реализации

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

fn type_id(&self) -> TypeId

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

impl<W> AsyncWriteExt for W
where W: AsyncWrite + ?Sized,

fn write<'a>(&'a mut self, src: &'a [u8]) -> Write<'a, Self>
where Self: Unpin,

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

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

fn write_vectored<'a, 'b>( &'a mut self, bufs: &'a [IoSlice<'b>], ) -> WriteVectored<'a, 'b, Self>
where Self: Unpin,

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

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

fn write_buf<'a, B>(&'a mut self, src: &'a mut B) -> WriteBuf<'a, Self, B>
where Self: Sized + Unpin, B: Buf,

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

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

fn write_all_buf<'a, B>( &'a mut self, src: &'a mut B, ) -> WriteAllBuf<'a, Self, B>
where Self: Sized + Unpin, B: Buf,

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

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

fn write_all<'a>(&'a mut self, src: &'a [u8]) -> WriteAll<'a, Self>
where Self: Unpin,

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

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

fn write_u8(&mut self, n: u8) -> WriteU8<&mut Self>
where Self: Unpin,

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

Записывает беззнаковое 8-битное целое число в нижележащий объект записи. Подробнее