fast_io: StreamReader.readinto method added.

Author: peterhinch

fast_io/__init__.py

@@ -164,6 +164,13 @@ def read(self, n=-1):
         # PollEventLoop._unregister
         return res  # Next iteration raises StopIteration and returns result
 
+    def readinto(self, buf, n=-1):  # Experimental and not yet tested TODO
+        yield IORead(self.polls)
+        res = self.ios.readinto(buf, n)
+        assert res, 'zero bytes returned'  # Temporary
+        yield IOReadDone(self.polls)
+        return res
+
     def readexactly(self, n):
         buf = b""
         while n:

lowpower/mqtt_log.py

@@ -6,11 +6,7 @@
 # On my SF_2W board consumption while paused was 170μA.
 
 # Test reception e.g. with:
-# mosquitto_sub -h 192.168.0.33 -t result
-
-SERVER = '192.168.0.33'  # *** Adapt for local conditions ***
-SSID = 'misspiggy'
-PW = '6163VMiqSTyx'
+# mosquitto_sub -h 192.168.0.10 -t result
 
 import rtc_time_cfg
 rtc_time_cfg.enabled = True
@@ -19,6 +15,7 @@
 from umqtt.simple import MQTTClient
 import network
 import ujson
+from local import SERVER, SSID, PW  # Local configuration: change this file
 
 import uasyncio as asyncio
 try:
@@ -42,7 +39,7 @@ async def main(loop):
     sta_if = network.WLAN()
     sta_if.active(True)
     sta_if.connect(SSID, PW)
-    while sta_if.status() == 1:
+    while sta_if.status() in (1, 2):  # https://github.com/micropython/micropython/issues/4682
         await asyncio.sleep(1)
         grn.toggle()
     if sta_if.isconnected():