Struct BoundedStream 

pub struct BoundedStream { /* private fields */ }

A bounded stream backed by a ring buffer.

When writes exceed capacity, the oldest data is evicted to make room. This prevents unbounded memory growth from chatty commands while still keeping recent output available for inspection.

Example

use kaish_kernel::scheduler::BoundedStream;

let stream = BoundedStream::new(100); // 100 byte max

stream.write(b"hello ").await;
stream.write(b"world").await;

let snapshot = stream.read().await;
assert_eq!(&snapshot, b"hello world");

Implementations

impl BoundedStream

pub fn new(max_size: usize) -> Self

Create a new bounded stream with the specified maximum size.

pub fn default_size() -> Self

Create a new bounded stream with the default max size (10MB).

pub async fn write(&self, data: &[u8])

Write data to the stream.

If the write would exceed capacity, the oldest data is evicted first. Writing to a closed stream is silently ignored.

pub async fn read(&self) -> Vec<u8>

Read a snapshot of the current buffer contents.

Returns a copy of all data currently in the buffer. The buffer is not modified.

pub async fn read_string(&self) -> String

Read the current buffer as a string (lossy UTF-8 conversion).

pub async fn close(&self)

Close the stream, indicating no more writes are expected.

Subsequent writes will be silently ignored.

pub async fn is_closed(&self) -> bool

Check if the stream has been closed.

pub async fn len(&self) -> usize

Get the current buffer size in bytes.

pub async fn is_empty(&self) -> bool

Check if the buffer is empty.

pub async fn stats(&self) -> StreamStats

Get stream statistics.

Trait Implementations

impl Clone for BoundedStream

fn clone(&self) -> BoundedStream

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BoundedStream

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

Formats the value using the given formatter.