parent
9a447f1359
commit
9772645718
1 changed files with 2 additions and 2 deletions
|
@ -268,9 +268,9 @@ impl<'d, U: UarteInstance, T: TimerInstance> embedded_io::asynch::BufRead
|
|||
|
||||
fn consume(&mut self, amt: usize) {
|
||||
let signal = self.inner.with(|state| {
|
||||
let empty = state.rx.is_empty();
|
||||
let full = state.rx.is_full();
|
||||
state.rx.pop(amt);
|
||||
!empty
|
||||
full
|
||||
});
|
||||
if signal {
|
||||
self.inner.pend();
|
||||
|
|
Loading…
Reference in a new issue