Struct TestSendBuffer 

pub struct TestSendBuffer { /* private fields */ }

An implementation of SendBuffer for tests.

Implementations

impl TestSendBuffer

pub fn new(fake_stream: Arc<Mutex<Vec<u8>>>, ring: RingBuffer) -> TestSendBuffer

Creates a new TestSendBuffer with a backing shared vec and a helper ring buffer.

Trait Implementations

impl Buffer for TestSendBuffer

fn limits(&self) -> BufferLimits

Returns information about the number of bytes in the buffer.

fn target_capacity(&self) -> usize

Gets the target size of the buffer, in bytes.

fn request_capacity(&mut self, size: usize)

Requests that the buffer be resized to hold the given number of bytes.

impl Debug for TestSendBuffer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TestSendBuffer

fn default() -> TestSendBuffer

Returns the “default value” for a type.

impl IntoBuffers<Arc<Mutex<RingBuffer>>, TestSendBuffer> for ProvidedBuffers

fn into_buffers( self, buffer_sizes: BufferSizes, ) -> (Arc<Mutex<RingBuffer>>, TestSendBuffer)

Converts to receive and send buffers.

impl SendBuffer for TestSendBuffer

type Payload<'a> = FragmentedPayload<'a, 2>

The payload type given to peek_with.

fn mark_read(&mut self, count: usize)

Removes count bytes from the beginning of the buffer as already read.

fn peek_with<'a, F, R>(&'a mut self, offset: usize, f: F) -> R

where F: FnOnce(Self::Payload<'a>) -> R,

Calls f with contiguous sequences of readable bytes in the buffer without advancing the reading pointer.