MyAsync

My simple implementation of asynchronous in Python

Setup

• Create venv

python -m venv .venv 

• Activate venv

. .venv/bin/activate 

• Install myasync

pip install myasync@git+https://github.com/KrySeyt/myasync.git

Run example

• Install myasync with example

pip install myasync@git+https://github.com/KrySeyt/myasync.git

• Run example server

python -m example_server &

• Run example client

python -m example_client 

Introducing

• Await - socket with expected I/O type. Yield it from Coroutine
• Await Coroutine and Task with yield from
• If Coroutine are not ready and it should be called later just yield None from coro. sleep and Lock works this way
• If you wanna have async interface, but in current implementation nothing to yield or yield from
  (no sockets, no Coroutines and no Tasks), just yield None or yield from myasync.sleep(0). Example:

import myasync

def io_operation(data: str) -> myasync.Coroutine[None]:
    # Mock implementation
    yield None
    
    print(f"Data: {data}")

Code example

import time
import socket

from myasync import Coroutine, Await, IOType, gather, run

def send_request() -> Coroutine[str]:
    """
    Example function that requires await socket
    """
    
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.connect(("localhost", 8000))
    sock.send(b"GET / HTTP/1.1\r\nHost:localhost\r\n\r\n")

    yield Await(sock, IOType.INPUT)

    sock.recv(100)
    sock.close()

    print("Task done")

    return "Done"


def main() -> Coroutine[None]:
    start = time.time()

    yield from gather(
        send_request(),
        send_request(),
        send_request(),
        send_request(),
    )

    end = time.time()
    print(end - start)


if __name__ == "__main__":
    run(main())