module asyncio

Source: stdlib/asyncio.codon

---

WorkItem @tuple Class is named tuple (cannot write fields)

Fields

coro: cobj

task: cobj

result_size: int

---

WorkNode

Fields

work: WorkItem

prev: Optional[WorkNode]

next: Optional[WorkNode]

Magic methods

__init__(self, work: WorkItem)

Methods

cancelled(self)

---

Timer

Fields

work: WorkItem

when: float

Methods

cancelled(self)

---

EventLoop

---

Handle @tuple Class is named tuple (cannot write fields)

Methods

cancel(self)

cancelled(self)

---

TimerHandle @tuple Class is named tuple (cannot write fields)

Methods

cancel(self)

cancelled(self)

when(self)

---

Future[R]

Fields

R: type

---

Task[R]

Fields

R: type

---

WorkItem @extend Class is extended to add given methods

Magic methods

__new__(coro: cobj)

__new__(coro: Coroutine)

__new__(task: Task)

__new__()

Methods

raw_task(self)

cancelled(self)

---

InvalidStateError

Magic methods

__init__(self, message: str = "")

---

CancelledError

Magic methods

__init__(self, message: str = "")

---

EventLoop @extend Class is extended to add given methods

Magic methods

__init__(self)

Methods

close(self)

time(self)

stop(self)

is_running(self)

is_closed(self)

call_soon(self, callback, *args)

call_soon_threadsafe(self, callback, *args)

call_later(self, delay: float, callback, *args)

call_at(self, delay: float, callback, *args)

run_forever(self)

run_until_complete(self, future)

create_future(self, T: type = NoneType)

create_task(self, coro: Coroutine, name: Optional[str] = None)

---

Future[R] @extend Class is extended to add given methods

Magic methods

__init__(self, loop: Optional[EventLoop] = None)

__await__(self)

Methods

add_done_callback(self, callback)

result(self)

set_result(self, result: R)

set_exception(self, exception: BaseException)

cancelled(self)

done(self)

cancel(self, msg: Optional[str] = None)

get_loop(self)

exception(self)

---

Task[R] @extend Class is extended to add given methods

Magic methods

__init__(self, coro: Coroutine[R], loop: Optional[EventLoop] = None, name: Optional[str] = None)

__await__(self)

Methods

get_name(self)

set_name(self, value: str)

get_coro(self, T: type = NoneType)

add_done_callback(self, callback)

get_loop(self)

done(self)

cancelled(self)

result(self)

cancel(self, msg: Optional[str] = None)

---

new_event_loop()

---

set_event_loop(loop: EventLoop)

---

get_event_loop()

---

get_running_loop()

---

create_task(coro, name: Optional[str] = None)

---

isfuture(obj)

---

iscoroutine(obj)

---

ensure_future(obj, loop: Optional[EventLoop] = None)

---

current_task()

---

run(coro, debug = None, loop_factory = None)

---

sleep(delay: float, result = None)

---

gather(*aws)