Структура Split

Возвращает следующий сегмент потока.

Примеры

use tokio::io::AsyncBufReadExt;

let mut segments = my_buf_read.split(b'f');

while let Some(segment) = segments.next_segment().await? {
    println!("length = {}", segment.len())
}

Проверяет наличие следующего сегмента в потоке.

Этот метод возвращает:

• Poll::Pending, если следующий сегмент ещё недоступен.
• Poll::Ready(Ok(Some(segment))), если следующий сегмент доступен.
• Poll::Ready(Ok(None)), если в этом потоке больше нет сегментов.
• Poll::Ready(Err(err)), если при чтении следующего сегмента произошла ошибка ввода-вывода.

Если метод возвращает Poll::Pending, для Waker в переданном Context будет запланировано пробуждение, когда в базовом ресурсе ввода-вывода появятся дополнительные байты.

Обратите внимание: при нескольких вызовах poll_next_segment пробуждение будет запланировано только для Waker из Context, переданного при последнем вызове.

Возвращает аргумент без изменений.

Вызывает U::from(self).

Иными словами, это преобразование выполняет действия, выбранные реализацией From<T> for U.