Lines Matching full:take
9 /// Reader for the [`take`](super::AsyncReadExt::take) method.
12 pub struct Take<R> {
19 impl<R: AsyncRead> Take<R> { impl
41 /// let mut take = reader.take(4);
42 /// let n = take.read(&mut buffer).await?;
44 /// assert_eq!(take.limit(), 2);
52 /// return EOF. This is the same as constructing a new `Take` instance, so
65 /// let mut take = reader.take(4);
66 /// let n = take.read(&mut buffer).await?;
69 /// assert_eq!(take.limit(), 0);
71 /// take.set_limit(10);
72 /// let n = take.read(&mut buffer).await?;
84 impl<R: AsyncRead> AsyncRead for Take<R> { implementation
103 impl<R: AsyncBufRead> AsyncBufRead for Take<R> { implementation