micropython/lora: Improve asynchronous support

This work was funded through GitHub Sponsors.

Signed-off-by: Angus Gratton <angus@redyak.com.au>

Author: projectgus

micropython/lora/async_modem.py

@@ -6,11 +6,6 @@
 import uasyncio
 
 
-def _clear_irqflag(thread_safe_flag):  # TODO: implement ThreadSafeFlag.clear() in MP
-    if thread_safe_flag:
-        thread_safe_flag._flag = 0
-
-
 class AsyncModem:
     def __init__(self, modem):
         self._modem = modem
@@ -20,28 +15,28 @@ def __init__(self, modem):
     def configure(self, lora_cfg, rx_calibrate=False):
         return self._modem.configure(lora_cfg, rx_calibrate)
 
-    async def receive(self, timeout_ms=None, rx_continuous=False):
+    async def receive(self, timeout_ms=None):
         # TODO: check for any pending TX
-        _clear_irqflag(self._flag)
-        will_cb = self._modem.start_receive(timeout_ms, rx_continuous)
+        self._flag.clear()
+        will_cb = self._modem.start_receive(timeout_ms)
         if will_cb:
             await self._flag.wait()
+            assert self._modem.is_receive_completed()
         else:
             while not self._modem.is_receive_completed():
                 await uasyncio.sleep_ms(0)
-                assert self._modem.is_receive_completed()  # TODO: remove?
-        return self._modem.end_receive(timeout_ms, rx_continuous)
+        return self._modem.end_receive(timeout_ms)
 
     async def transmit(self, message):
-        _clear_irqflag(self._flag)
-        will_cb, was_rx = self._modem.start_transmit(message)
+        self._flag.clear()
+        will_cb = self._modem.start_transmit(message)
         if will_cb:
             await self._flag.wait()
-            assert self._modem.is_transmit_completed()  # TODO: remove?
+            assert self._modem.is_transmit_completed()
         else:
             while not self._modem.is_transmit_completed():
                 await uasyncio.sleep_ms(0)
-        self._modem.end_transmit(was_rx)
+        self._modem.end_transmit()
 
     def _callback(self):
         self._flag.set()