[−][src]Struct bytes::BytesMut
A unique reference to a contiguous slice of memory.
BytesMut
represents a unique view into a potentially shared memory region.
Given the uniqueness guarantee, owners of BytesMut
handles are able to
mutate the memory. It is similar to a Vec<u8>
but with less copies and
allocations.
For more detail, see Bytes.
Growth
One key difference from Vec<u8>
is that most operations do not
implicitly grow the buffer. This means that calling my_bytes.put("hello world");
could panic if my_bytes
does not have enough capacity. Before
writing to the buffer, ensure that there is enough remaining capacity by
calling my_bytes.remaining_mut()
. In general, avoiding calls to reserve
is preferable.
The only exception is extend
which implicitly reserves required capacity.
Examples
use bytes::{BytesMut, BufMut}; let mut buf = BytesMut::with_capacity(64); buf.put(b'h'); buf.put(b'e'); buf.put("llo"); assert_eq!(&buf[..], b"hello"); // Freeze the buffer so that it can be shared let a = buf.freeze(); // This does not allocate, instead `b` points to the same memory. let b = a.clone(); assert_eq!(&a[..], b"hello"); assert_eq!(&b[..], b"hello");
Methods
impl BytesMut
[src]
[−]
impl BytesMut
pub fn with_capacity(capacity: usize) -> BytesMut
[src]
[−]
pub fn with_capacity(capacity: usize) -> BytesMut
Creates a new BytesMut
with the specified capacity.
The returned BytesMut
will be able to hold at least capacity
bytes
without reallocating. If capacity
is under 4 * size_of::<usize>() - 1
,
then BytesMut
will not allocate.
It is important to note that this function does not specify the length
of the returned BytesMut
, but only the capacity.
Examples
use bytes::{BytesMut, BufMut}; let mut bytes = BytesMut::with_capacity(64); // `bytes` contains no data, even though there is capacity assert_eq!(bytes.len(), 0); bytes.put(&b"hello world"[..]); assert_eq!(&bytes[..], b"hello world");
pub fn new() -> BytesMut
[src]
[−]
pub fn new() -> BytesMut
Creates a new BytesMut
with default capacity.
Resulting object has length 0 and unspecified capacity. This function does not allocate.
Examples
use bytes::{BytesMut, BufMut}; let mut bytes = BytesMut::new(); assert_eq!(0, bytes.len()); bytes.reserve(2); bytes.put_slice(b"xy"); assert_eq!(&b"xy"[..], &bytes[..]);
pub fn len(&self) -> usize
[src]
[−]
pub fn len(&self) -> usize
Returns the number of bytes contained in this BytesMut
.
Examples
use bytes::BytesMut; let b = BytesMut::from(&b"hello"[..]); assert_eq!(b.len(), 5);
pub fn is_empty(&self) -> bool
[src]
[−]
pub fn is_empty(&self) -> bool
Returns true if the BytesMut
has a length of 0.
Examples
use bytes::BytesMut; let b = BytesMut::with_capacity(64); assert!(b.is_empty());
pub fn capacity(&self) -> usize
[src]
[−]
pub fn capacity(&self) -> usize
Returns the number of bytes the BytesMut
can hold without reallocating.
Examples
use bytes::BytesMut; let b = BytesMut::with_capacity(64); assert_eq!(b.capacity(), 64);
pub fn freeze(self) -> Bytes
[src]
[−]
pub fn freeze(self) -> Bytes
Converts self
into an immutable Bytes
.
The conversion is zero cost and is used to indicate that the slice referenced by the handle will no longer be mutated. Once the conversion is done, the handle can be cloned and shared across threads.
Examples
use bytes::{BytesMut, BufMut}; use std::thread; let mut b = BytesMut::with_capacity(64); b.put("hello world"); let b1 = b.freeze(); let b2 = b1.clone(); let th = thread::spawn(move || { assert_eq!(&b1[..], b"hello world"); }); assert_eq!(&b2[..], b"hello world"); th.join().unwrap();
pub fn split_off(&mut self, at: usize) -> BytesMut
[src]
[−]
pub fn split_off(&mut self, at: usize) -> BytesMut
Splits the bytes into two at the given index.
Afterwards self
contains elements [0, at)
, and the returned
BytesMut
contains elements [at, capacity)
.
This is an O(1)
operation that just increases the reference count
and sets a few indices.
Examples
use bytes::BytesMut; let mut a = BytesMut::from(&b"hello world"[..]); let mut b = a.split_off(5); a[0] = b'j'; b[0] = b'!'; assert_eq!(&a[..], b"jello"); assert_eq!(&b[..], b"!world");
Panics
Panics if at > capacity
.
pub fn take(&mut self) -> BytesMut
[src]
[−]
pub fn take(&mut self) -> BytesMut
Removes the bytes from the current view, returning them in a new
BytesMut
handle.
Afterwards, self
will be empty, but will retain any additional
capacity that it had before the operation. This is identical to
self.split_to(self.len())
.
This is an O(1)
operation that just increases the reference count and
sets a few indices.
Examples
use bytes::{BytesMut, BufMut}; let mut buf = BytesMut::with_capacity(1024); buf.put(&b"hello world"[..]); let other = buf.take(); assert!(buf.is_empty()); assert_eq!(1013, buf.capacity()); assert_eq!(other, b"hello world"[..]);
pub fn split_to(&mut self, at: usize) -> BytesMut
[src]
[−]
pub fn split_to(&mut self, at: usize) -> BytesMut
Splits the buffer into two at the given index.
Afterwards self
contains elements [at, len)
, and the returned BytesMut
contains elements [0, at)
.
This is an O(1)
operation that just increases the reference count and
sets a few indices.
Examples
use bytes::BytesMut; let mut a = BytesMut::from(&b"hello world"[..]); let mut b = a.split_to(5); a[0] = b'!'; b[0] = b'j'; assert_eq!(&a[..], b"!world"); assert_eq!(&b[..], b"jello");
Panics
Panics if at > len
.
pub fn truncate(&mut self, len: usize)
[src]
[−]
pub fn truncate(&mut self, len: usize)
Shortens the buffer, keeping the first len
bytes and dropping the
rest.
If len
is greater than the buffer's current length, this has no
effect.
The split_off
method can emulate truncate
, but this causes the
excess bytes to be returned instead of dropped.
Examples
use bytes::BytesMut; let mut buf = BytesMut::from(&b"hello world"[..]); buf.truncate(5); assert_eq!(buf, b"hello"[..]);
pub fn advance(&mut self, cnt: usize)
[src]
[−]
pub fn advance(&mut self, cnt: usize)
Shortens the buffer, dropping the first cnt
bytes and keeping the
rest.
This is the same function as Buf::advance
, and in the next breaking
release of bytes
, this implementation will be removed in favor of
having BytesMut
implement Buf
.
Panics
This function panics if cnt
is greater than self.len()
pub fn clear(&mut self)
[src]
[−]
pub fn clear(&mut self)
Clears the buffer, removing all data.
Examples
use bytes::BytesMut; let mut buf = BytesMut::from(&b"hello world"[..]); buf.clear(); assert!(buf.is_empty());
pub fn resize(&mut self, new_len: usize, value: u8)
[src]
[−]
pub fn resize(&mut self, new_len: usize, value: u8)
Resizes the buffer so that len
is equal to new_len
.
If new_len
is greater than len
, the buffer is extended by the
difference with each additional byte set to value
. If new_len
is
less than len
, the buffer is simply truncated.
Examples
use bytes::BytesMut; let mut buf = BytesMut::new(); buf.resize(3, 0x1); assert_eq!(&buf[..], &[0x1, 0x1, 0x1]); buf.resize(2, 0x2); assert_eq!(&buf[..], &[0x1, 0x1]); buf.resize(4, 0x3); assert_eq!(&buf[..], &[0x1, 0x1, 0x3, 0x3]);
pub unsafe fn set_len(&mut self, len: usize)
[src]
[−]
pub unsafe fn set_len(&mut self, len: usize)
Sets the length of the buffer.
This will explicitly set the size of the buffer without actually modifying the data, so it is up to the caller to ensure that the data has been initialized.
Examples
use bytes::BytesMut; let mut b = BytesMut::from(&b"hello world"[..]); unsafe { b.set_len(5); } assert_eq!(&b[..], b"hello"); unsafe { b.set_len(11); } assert_eq!(&b[..], b"hello world");
Panics
This method will panic if len
is out of bounds for the underlying
slice or if it comes after the end
of the configured window.
pub fn reserve(&mut self, additional: usize)
[src]
[−]
pub fn reserve(&mut self, additional: usize)
Reserves capacity for at least additional
more bytes to be inserted
into the given BytesMut
.
More than additional
bytes may be reserved in order to avoid frequent
reallocations. A call to reserve
may result in an allocation.
Before allocating new buffer space, the function will attempt to reclaim space in the existing buffer. If the current handle references a small view in the original buffer and all other handles have been dropped, and the requested capacity is less than or equal to the existing buffer's capacity, then the current view will be copied to the front of the buffer and the handle will take ownership of the full buffer.
Examples
In the following example, a new buffer is allocated.
use bytes::BytesMut; let mut buf = BytesMut::from(&b"hello"[..]); buf.reserve(64); assert!(buf.capacity() >= 69);
In the following example, the existing buffer is reclaimed.
use bytes::{BytesMut, BufMut}; let mut buf = BytesMut::with_capacity(128); buf.put(&[0; 64][..]); let ptr = buf.as_ptr(); let other = buf.take(); assert!(buf.is_empty()); assert_eq!(buf.capacity(), 64); drop(other); buf.reserve(128); assert_eq!(buf.capacity(), 128); assert_eq!(buf.as_ptr(), ptr);
Panics
Panics if the new capacity overflows usize
.
pub fn extend_from_slice(&mut self, extend: &[u8])
[src]
[−]
pub fn extend_from_slice(&mut self, extend: &[u8])
Appends given bytes to this object.
If this BytesMut
object has not enough capacity, it is resized first.
So unlike put_slice
operation, extend_from_slice
does not panic.
Examples
use bytes::BytesMut; let mut buf = BytesMut::with_capacity(0); buf.extend_from_slice(b"aaabbb"); buf.extend_from_slice(b"cccddd"); assert_eq!(b"aaabbbcccddd", &buf[..]);
pub fn unsplit(&mut self, other: BytesMut)
[src]
[−]
pub fn unsplit(&mut self, other: BytesMut)
Combine splitted BytesMut objects back as contiguous.
If BytesMut
objects were not contiguous originally, they will be extended.
Examples
use bytes::BytesMut; let mut buf = BytesMut::with_capacity(64); buf.extend_from_slice(b"aaabbbcccddd"); let splitted = buf.split_off(6); assert_eq!(b"aaabbb", &buf[..]); assert_eq!(b"cccddd", &splitted[..]); buf.unsplit(splitted); assert_eq!(b"aaabbbcccddd", &buf[..]);
Trait Implementations
impl BufMut for BytesMut
[src]
[+]
impl BufMut for BytesMut
impl FromBuf for BytesMut
[src]
[+]
impl FromBuf for BytesMut
impl IntoBuf for BytesMut
[src]
[+]
impl IntoBuf for BytesMut
impl<'a> IntoBuf for &'a BytesMut
[src]
[+]
impl<'a> IntoBuf for &'a BytesMut
impl AsMut<[u8]> for BytesMut
[src]
[+]
impl AsMut<[u8]> for BytesMut
impl PartialOrd<BytesMut> for BytesMut
[src]
[+]
impl PartialOrd<BytesMut> for BytesMut
impl PartialOrd<[u8]> for BytesMut
[src]
[+]
impl PartialOrd<[u8]> for BytesMut
impl PartialOrd<BytesMut> for [u8]
[src]
[+]
impl PartialOrd<BytesMut> for [u8]
impl PartialOrd<str> for BytesMut
[src]
[+]
impl PartialOrd<str> for BytesMut
impl PartialOrd<BytesMut> for str
[src]
[+]
impl PartialOrd<BytesMut> for str
impl PartialOrd<Vec<u8>> for BytesMut
[src]
[+]
impl PartialOrd<Vec<u8>> for BytesMut
impl PartialOrd<BytesMut> for Vec<u8>
[src]
[+]
impl PartialOrd<BytesMut> for Vec<u8>
impl PartialOrd<String> for BytesMut
[src]
[+]
impl PartialOrd<String> for BytesMut
impl PartialOrd<BytesMut> for String
[src]
[+]
impl PartialOrd<BytesMut> for String
impl<'a, T: ?Sized> PartialOrd<&'a T> for BytesMut where
BytesMut: PartialOrd<T>,
[src]
[+]
impl<'a, T: ?Sized> PartialOrd<&'a T> for BytesMut where
BytesMut: PartialOrd<T>,
impl<'a> PartialOrd<BytesMut> for &'a [u8]
[src]
[+]
impl<'a> PartialOrd<BytesMut> for &'a [u8]
impl<'a> PartialOrd<BytesMut> for &'a str
[src]
[+]
impl<'a> PartialOrd<BytesMut> for &'a str
impl Default for BytesMut
[src]
[+]
impl Default for BytesMut
impl Ord for BytesMut
[src]
[+]
impl Ord for BytesMut
impl PartialEq<BytesMut> for BytesMut
[src]
[+]
impl PartialEq<BytesMut> for BytesMut
impl PartialEq<[u8]> for BytesMut
[src]
[+]
impl PartialEq<[u8]> for BytesMut
impl PartialEq<BytesMut> for [u8]
[src]
[+]
impl PartialEq<BytesMut> for [u8]
impl PartialEq<str> for BytesMut
[src]
[+]
impl PartialEq<str> for BytesMut
impl PartialEq<BytesMut> for str
[src]
[+]
impl PartialEq<BytesMut> for str
impl PartialEq<Vec<u8>> for BytesMut
[src]
[+]
impl PartialEq<Vec<u8>> for BytesMut
impl PartialEq<BytesMut> for Vec<u8>
[src]
[+]
impl PartialEq<BytesMut> for Vec<u8>
impl PartialEq<String> for BytesMut
[src]
[+]
impl PartialEq<String> for BytesMut
impl PartialEq<BytesMut> for String
[src]
[+]
impl PartialEq<BytesMut> for String
impl<'a, T: ?Sized> PartialEq<&'a T> for BytesMut where
BytesMut: PartialEq<T>,
[src]
[+]
impl<'a, T: ?Sized> PartialEq<&'a T> for BytesMut where
BytesMut: PartialEq<T>,
impl<'a> PartialEq<BytesMut> for &'a [u8]
[src]
[+]
impl<'a> PartialEq<BytesMut> for &'a [u8]
impl<'a> PartialEq<BytesMut> for &'a str
[src]
[+]
impl<'a> PartialEq<BytesMut> for &'a str
impl PartialEq<BytesMut> for Bytes
[src]
[+]
impl PartialEq<BytesMut> for Bytes
impl PartialEq<Bytes> for BytesMut
[src]
[+]
impl PartialEq<Bytes> for BytesMut
impl From<BytesMut> for Bytes
[src]
[+]
impl From<BytesMut> for Bytes
impl From<Vec<u8>> for BytesMut
[src]
[+]
impl From<Vec<u8>> for BytesMut
impl From<String> for BytesMut
[src]
[+]
impl From<String> for BytesMut
impl<'a> From<&'a [u8]> for BytesMut
[src]
[+]
impl<'a> From<&'a [u8]> for BytesMut
impl<'a> From<&'a str> for BytesMut
[src]
[+]
impl<'a> From<&'a str> for BytesMut
impl From<Bytes> for BytesMut
[src]
[+]
impl From<Bytes> for BytesMut
impl AsRef<[u8]> for BytesMut
[src]
[+]
impl AsRef<[u8]> for BytesMut
impl Clone for BytesMut
[src]
[+]
impl Clone for BytesMut
impl IntoIterator for BytesMut
[src]
[+]
impl IntoIterator for BytesMut
impl<'a> IntoIterator for &'a BytesMut
[src]
[+]
impl<'a> IntoIterator for &'a BytesMut
impl Extend<u8> for BytesMut
[src]
[+]
impl Extend<u8> for BytesMut
impl<'a> Extend<&'a u8> for BytesMut
[src]
[+]
impl<'a> Extend<&'a u8> for BytesMut
impl Eq for BytesMut
[src]
impl Eq for BytesMut
impl Deref for BytesMut
[src]
[+]
impl Deref for BytesMut
impl Hash for BytesMut
[src]
[+]
impl Hash for BytesMut
impl DerefMut for BytesMut
[src]
[+]
impl DerefMut for BytesMut
impl FromIterator<u8> for BytesMut
[src]
[+]
impl FromIterator<u8> for BytesMut
impl Debug for BytesMut
[src]
[+]
impl Debug for BytesMut
impl Write for BytesMut
[src]
[+]
impl Write for BytesMut
impl Borrow<[u8]> for BytesMut
[src]
[+]
impl Borrow<[u8]> for BytesMut
impl BorrowMut<[u8]> for BytesMut
[src]
[+]
impl BorrowMut<[u8]> for BytesMut
Auto Trait Implementations
Blanket Implementations
impl<T, U> Into for T where
U: From<T>,
[src]
[−]
impl<T, U> Into for T where
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
[−]
impl<T> ToOwned for T where
T: Clone,
type Owned = T
fn to_owned(&self) -> T
[src]
[−]
fn to_owned(&self) -> T
Creates owned data from borrowed data, usually by cloning. Read more
fn clone_into(&self, target: &mut T)
[src]
[−]
fn clone_into(&self, target: &mut T)
🔬 This is a nightly-only experimental API. (toowned_clone_into
)
recently added
Uses borrowed data to replace owned data, usually by cloning. Read more
impl<T> From for T
[src]
[−]
impl<T> From for T
impl<I> IntoIterator for I where
I: Iterator,
[src]
[−]
impl<I> IntoIterator for I where
I: Iterator,
type Item = <I as Iterator>::Item
The type of the elements being iterated over.
type IntoIter = I
Which kind of iterator are we turning this into?
fn into_iter(self) -> I
[src]
[−]
fn into_iter(self) -> I
Creates an iterator from a value. Read more
impl<T, U> TryFrom for T where
T: From<U>,
[src]
[−]
impl<T, U> TryFrom for T where
T: From<U>,
type Error = !
try_from
)The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
[−]
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
try_from
)Performs the conversion.
impl<T> Borrow for T where
T: ?Sized,
[src]
[−]
impl<T> Borrow for T where
T: ?Sized,
impl<T> BorrowMut for T where
T: ?Sized,
[src]
[−]
impl<T> BorrowMut for T where
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
[−]
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<T, U> TryInto for T where
U: TryFrom<T>,
[src]
[−]
impl<T, U> TryInto for T where
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
try_from
)The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
[−]
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
try_from
)Performs the conversion.
impl<T> Any for T where
T: 'static + ?Sized,
[src]
[−]
impl<T> Any for T where
T: 'static + ?Sized,
fn get_type_id(&self) -> TypeId
[src]
[−]
fn get_type_id(&self) -> TypeId
🔬 This is a nightly-only experimental API. (get_type_id
)
this method will likely be replaced by an associated static
Gets the TypeId
of self
. Read more