Struct AsyncStream 

pub struct AsyncStream<const N: usize> { /* private fields */ }

Async wrapper around an ove::Stream.

Owns the wrapped stream and the AtomicWaker used to bridge the C-level notify hook into the embassy executor’s wake path.

Implementations

impl<const N: usize> AsyncStream<N>

pub const fn new(inner: Stream<N>) -> Self

Wrap a stream for async use. Does not arm the notify hook yet — call Self::arm after the wrapper has reached its final ’static location (the C callback retains a pointer to the internal AtomicWaker, so the wrapper must not move after arming).

pub fn arm(&'static self) -> Result<()>

Register the C-side notify callback. Must be called exactly once, and only after the wrapper is at its final ’static address.

pub async fn read(&'static self, buf: &mut [u8]) -> Result<usize>

Receive up to buf.len() bytes. Awaits until at least one byte is available, then returns the number of bytes copied.

Returns Ok(0) only if buf.is_empty().

pub fn inner(&self) -> &Stream<N>

Borrow the underlying Stream for synchronous operations (send, bytes_available, …). The async read is the only path that touches the AtomicWaker; non-blocking access through this borrow is independent.

Trait Implementations

impl<const N: usize> ErrorType for &'static AsyncStream<N>

type Error = Error

Error type of all the IO operations on this type.

impl<const N: usize> Read for &'static AsyncStream<N>

async fn read(&mut self, buf: &mut [u8]) -> Result<usize, Self::Error>

Read some bytes from this source into the specified buffer, returning how many bytes were read.

async fn read_exact( &mut self, buf: &mut [u8], ) -> Result<(), ReadExactError<Self::Error>>

Read the exact number of bytes required to fill buf.

impl<const N: usize> Send for AsyncStream<N>

impl<const N: usize> Sync for AsyncStream<N>