johanste

import asyncio
import threading


class Client:
    def __enter__(self):
        return self

    def __exit__(self, exc_type, exc_value, traceback):
        self.loop.call_soon_threadsafe(self.loop.stop)

johanste

from sys import Type
from typing import List

class Policy:
    ...


class RetryPolicy(Policy):

    def __init__(self, max_retries=4, timeout=None):