Struct async_stm32f1xx::serial::RxStream

#[must_use = "streams do nothing unless polled"]pub struct RxStream<BUF, PAYLOAD> where
    BUF: 'static,  { /* fields omitted */ }

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>>

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>>

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>>

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.