Struct bytes::buf::ext::Take [−][src]
A Buf
adapter which limits the bytes read from an underlying buffer.
This struct is generally created by calling take()
on Buf
. See
documentation of take()
for more details.
Implementations
impl<T> Take<T>
[src]
pub fn into_inner(self) -> T
[src]
Consumes this Take
, returning the underlying value.
Examples
use bytes::buf::{BufMut, BufExt}; let mut buf = b"hello world".take(2); let mut dst = vec![]; dst.put(&mut buf); assert_eq!(*dst, b"he"[..]); let mut buf = buf.into_inner(); dst.clear(); dst.put(&mut buf); assert_eq!(*dst, b"llo world"[..]);
pub fn get_ref(&self) -> &T
[src]
Gets a reference to the underlying Buf
.
It is inadvisable to directly read from the underlying Buf
.
Examples
use bytes::{Buf, buf::BufExt}; let buf = b"hello world".take(2); assert_eq!(11, buf.get_ref().remaining());
pub fn get_mut(&mut self) -> &mut T
[src]
Gets a mutable reference to the underlying Buf
.
It is inadvisable to directly read from the underlying Buf
.
Examples
use bytes::{Buf, BufMut, buf::BufExt}; let mut buf = b"hello world".take(2); let mut dst = vec![]; buf.get_mut().advance(2); dst.put(&mut buf); assert_eq!(*dst, b"ll"[..]);
pub fn limit(&self) -> usize
[src]
Returns the maximum number of bytes that can be read.
Note
If the inner Buf
has fewer bytes than indicated by this method then
that is the actual number of available bytes.
Examples
use bytes::{Buf, buf::BufExt}; let mut buf = b"hello world".take(2); assert_eq!(2, buf.limit()); assert_eq!(b'h', buf.get_u8()); assert_eq!(1, buf.limit());
pub fn set_limit(&mut self, lim: usize)
[src]
Sets the maximum number of bytes that can be read.
Note
If the inner Buf
has fewer bytes than lim
then that is the actual
number of available bytes.
Examples
use bytes::{BufMut, buf::BufExt}; let mut buf = b"hello world".take(2); let mut dst = vec![]; dst.put(&mut buf); assert_eq!(*dst, b"he"[..]); dst.clear(); buf.set_limit(3); dst.put(&mut buf); assert_eq!(*dst, b"llo"[..]);
Trait Implementations
impl<T: Buf> Buf for Take<T>
[src]
fn remaining(&self) -> usize
[src]
fn bytes(&self) -> &[u8]ⓘ
[src]
fn advance(&mut self, cnt: usize)
[src]
fn bytes_vectored<'a>(&'a self, dst: &mut [IoSlice<'a>]) -> usize
[src]
fn has_remaining(&self) -> bool
[src]
fn copy_to_slice(&mut self, dst: &mut [u8])
[src]
fn get_u8(&mut self) -> u8
[src]
fn get_i8(&mut self) -> i8
[src]
fn get_u16(&mut self) -> u16
[src]
fn get_u16_le(&mut self) -> u16
[src]
fn get_i16(&mut self) -> i16
[src]
fn get_i16_le(&mut self) -> i16
[src]
fn get_u32(&mut self) -> u32
[src]
fn get_u32_le(&mut self) -> u32
[src]
fn get_i32(&mut self) -> i32
[src]
fn get_i32_le(&mut self) -> i32
[src]
fn get_u64(&mut self) -> u64
[src]
fn get_u64_le(&mut self) -> u64
[src]
fn get_i64(&mut self) -> i64
[src]
fn get_i64_le(&mut self) -> i64
[src]
fn get_u128(&mut self) -> u128
[src]
fn get_u128_le(&mut self) -> u128
[src]
fn get_i128(&mut self) -> i128
[src]
fn get_i128_le(&mut self) -> i128
[src]
fn get_uint(&mut self, nbytes: usize) -> u64
[src]
fn get_uint_le(&mut self, nbytes: usize) -> u64
[src]
fn get_int(&mut self, nbytes: usize) -> i64
[src]
fn get_int_le(&mut self, nbytes: usize) -> i64
[src]
fn get_f32(&mut self) -> f32
[src]
fn get_f32_le(&mut self) -> f32
[src]
fn get_f64(&mut self) -> f64
[src]
fn get_f64_le(&mut self) -> f64
[src]
fn to_bytes(&mut self) -> Bytes
[src]
impl<T: Debug> Debug for Take<T>
[src]
Auto Trait Implementations
impl<T> RefUnwindSafe for Take<T> where
T: RefUnwindSafe,
T: RefUnwindSafe,
impl<T> Send for Take<T> where
T: Send,
T: Send,
impl<T> Sync for Take<T> where
T: Sync,
T: Sync,
impl<T> Unpin for Take<T> where
T: Unpin,
T: Unpin,
impl<T> UnwindSafe for Take<T> where
T: UnwindSafe,
T: UnwindSafe,
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<B> BufExt for B where
B: Buf + ?Sized,
[src]
B: Buf + ?Sized,
fn take(self, limit: usize) -> Take<Self> where
Self: Sized,
[src]
Self: Sized,
fn chain<U: Buf>(self, next: U) -> Chain<Self, U> where
Self: Sized,
[src]
Self: Sized,
fn reader(self) -> Reader<Self>ⓘ where
Self: Sized,
[src]
Self: Sized,
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,