Struct RxStream

pub struct RxStream<BUF, PAYLOAD>
where
    BUF: 'static,
{ /* private fields */ }

A Stream-based asynchronous abstraction over a DMA receiver.

Examples

let mut tx_sink = TxSink3::new(tx_buf, tx.with_dma(channels.2));
let mut rx_stream = RxStream3::new(rx_buf, rx.with_dma(channels.3));
// Echoes USART3, by sending all items from the infinite RxStream
tx_sink.send_all(&mut rx_stream).await?;
unreachable!("rx_stream is empty");

Implementations

impl<BUF> RxStream<BUF, RxDma<Rx<USART1>, C5>>

where &'static mut [BUF; 2]: StaticWriteBuffer<Word = u8>,

pub fn new(buf: &'static mut [BUF; 2], rx: RxDma1) -> Self

where BUF: AsMutSlice<Element = u8>,

Creates a new RxStream from the specified buffers and DMA transmitter.

pub fn release(self) -> (&'static mut [BUF; 2], RxDma1)

Releases the buffers and DMA transmitter.

impl<BUF> RxStream<BUF, RxDma<Rx<USART2>, C6>>

where &'static mut [BUF; 2]: StaticWriteBuffer<Word = u8>,

pub fn new(buf: &'static mut [BUF; 2], rx: RxDma2) -> Self

where BUF: AsMutSlice<Element = u8>,

Creates a new RxStream from the specified buffers and DMA transmitter.

pub fn release(self) -> (&'static mut [BUF; 2], RxDma2)

Releases the buffers and DMA transmitter.

impl<BUF> RxStream<BUF, RxDma<Rx<USART3>, C3>>

where &'static mut [BUF; 2]: StaticWriteBuffer<Word = u8>,

pub fn new(buf: &'static mut [BUF; 2], rx: RxDma3) -> Self

where BUF: AsMutSlice<Element = u8>,

Creates a new RxStream from the specified buffers and DMA transmitter.

pub fn release(self) -> (&'static mut [BUF; 2], RxDma3)

Releases the buffers and DMA transmitter.