max/embassy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

impl. poll:ready

Browse Source
This commit is contained in:
xoviat 2020-12-30 19:45:07 -06:00
parent de2b1adafe
commit a5cf65a17b
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
embassy-stm32f4/src/serial.rs
View File

@ -242,20 +242,18 @@ impl<'a, B> Future for ReceiveFuture<'a, B>
where where
B: WriteBuffer<Word = u8> + 'static + Unpin, B: WriteBuffer<Word = u8> + 'static + Unpin,
{ {
type Output = (); type Output = B;
fn poll(self: core::pin::Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<()> { fn poll(self: core::pin::Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<B> {
let Self { uarte, rx_transfer } = unsafe { self.get_unchecked_mut() }; let Self { uarte, rx_transfer } = unsafe { self.get_unchecked_mut() };
if true { if true {
// self.rx_transfer.unwrap().is_done() {
let (rx_stream, usart, buf, _) = rx_transfer.take().unwrap().free(); let (rx_stream, usart, buf, _) = rx_transfer.take().unwrap().free();
uarte.rx_stream.replace(rx_stream); uarte.rx_stream.replace(rx_stream);
uarte.usart.replace(usart); uarte.usart.replace(usart);
// Poll::Ready((buf)) Poll::Ready(buf)
Poll::Ready(())
} else { } else {
waker_interrupt!(DMA2_STREAM2, cx.waker().clone()); waker_interrupt!(DMA2_STREAM2, cx.waker().clone());