read_until_slice/
async_buf_read_until_slice_ext.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
use crate::read_until_slice::{read_until_slice, ReadUntilSlice};
use tokio::io::AsyncBufRead;

pub trait AsyncBufReadUntilSliceExt: AsyncBufRead {
    fn read_until_slice<'a, 'b>(
        &'a mut self,
        delimiter: &'b [u8],
        buf: &'a mut Vec<u8>,
    ) -> ReadUntilSlice<'a, 'b, Self>
    where
        Self: Unpin,
    {
        read_until_slice(self, delimiter, buf)
    }
}

impl<R: AsyncBufRead + ?Sized> AsyncBufReadUntilSliceExt for R {}