From c3b899c470bd84ef4f0b8bdeca992ca1069a546c Mon Sep 17 00:00:00 2001 From: chemicstry Date: Thu, 26 May 2022 23:15:06 +0300 Subject: Implement BufRead for nrf BufferedUarte --- examples/nrf/src/bin/buffered_uart.rs | 20 +++++--------------- 1 file changed, 5 insertions(+), 15 deletions(-) (limited to 'examples') diff --git a/examples/nrf/src/bin/buffered_uart.rs b/examples/nrf/src/bin/buffered_uart.rs index a64c5821b..782c39499 100644 --- a/examples/nrf/src/bin/buffered_uart.rs +++ b/examples/nrf/src/bin/buffered_uart.rs @@ -6,7 +6,7 @@ use defmt::*; use embassy::executor::Spawner; use embassy_nrf::buffered_uarte::State; use embassy_nrf::{buffered_uarte::BufferedUarte, interrupt, uarte, Peripherals}; -use embedded_io::asynch::{Read, Write}; +use embedded_io::asynch::{BufRead, Write}; use futures::pin_mut; use defmt_rtt as _; // global logger @@ -46,23 +46,13 @@ async fn main(_spawner: Spawner, p: Peripherals) { unwrap!(u.write_all(b"Hello!\r\n").await); info!("wrote hello in uart!"); - // Simple demo, reading 8-char chunks and echoing them back reversed. loop { info!("reading..."); - let mut buf = [0u8; 8]; - unwrap!(u.read_exact(&mut buf).await); + let buf = unwrap!(u.fill_buf().await); info!("read done, got {}", buf); - // Reverse buf - for i in 0..4 { - buf.swap(i, 7 - i); - } - - info!("writing..."); - unwrap!(u.write_all(&buf).await); - info!("write done"); - - // Wait until the bytes are actually finished being transmitted - unwrap!(u.flush().await); + // Read bytes have to be explicitly consumed, otherwise fill_buf() will return them again + let n = buf.len(); + u.consume(n); } } -- cgit