mirror
/
micropython-lib
kopia lustrzana https://github.com/micropython/micropython-lib
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

asyncio_micro: Add support for starting a coroutine concurrently. 

Just yield it as a value. Also, improve logging/error reporting.
pull/11/head
Paul Sokolovsky 2014-05-03 23:20:22 +03:00
rodzic bfaf6b8d19
commit fe85cca848
1 zmienionych plików z 8 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

10
asyncio_micro/asyncio_micro.py
Wyświetl plik

@ -10,6 +10,7 @@ log = logging.getLogger("asyncio")
IO_READ = 1 IO_READ = 1
IO_WRITE = 2 IO_WRITE = 2
type_gen = type((lambda: (yield))())
class EventLoop: class EventLoop:
@ -60,9 +61,9 @@ class EventLoop:
try: try:
if args == (): if args == ():
args = (None,) args = (None,)
log.debug("Gen send args: %s", args) log.debug("Gen %s send args: %s", cb, args)
ret = cb.send(*args) ret = cb.send(*args)
log.debug("Gen yield result: %s", ret) log.debug("Gen %s yield result: %s", cb, ret)
if isinstance(ret, SysCall): if isinstance(ret, SysCall):
if isinstance(ret, Sleep): if isinstance(ret, Sleep):
delay = ret.args[0] delay = ret.args[0]
@ -79,6 +80,11 @@ class EventLoop:
self.remove_reader(ret.obj.fileno()) self.remove_reader(ret.obj.fileno())
elif ret.op == IO_WRITE: elif ret.op == IO_WRITE:
self.remove_writer(ret.obj.fileno()) self.remove_writer(ret.obj.fileno())
elif isinstance(ret, type_gen):
self.call_soon(ret)
else:
print(ret, type(ret))
assert False
except StopIteration as e: except StopIteration as e:
log.debug("Gen finished: %s", cb) log.debug("Gen finished: %s", cb)
continue continue