@@ -104,7 +104,7 @@ async def _run(self, vmin, vmax, div, mod, cb, args):
 def __aiter__(self):
 return self
 
-def __anext__(self):
+async def __anext__(self):
 await self._trig.wait()
 self._trig.clear()
 return self._cv