# Path: tests/moto_server.py
# _PYCHARM_HOSTED = os.environ.get('PYCHARM_HOSTED') == '1'
# _CONNECT_TIMEOUT = 90 if _PYCHARM_HOSTED else 10
# def get_free_tcp_port(release_socket: bool = False):
#     def __init__(self, service_name: str, port: int = None):
#     def endpoint_url(self):
#     def __call__(self, func):
#         async def wrapper(*args, **kwargs):
#     async def __aenter__(self):
#     async def __aexit__(self, exc_type, exc_val, exc_tb):
#     def _server_entry(self):
#     async def _start(self):
#     async def _stop(self):
# class MotoService:


import asyncio
import multiprocessing
import aiohttp
import aiohttp.web
import pytest
from aiohttp.web import StreamResponse
from tests.moto_server import host, MotoService, get_free_tcp_port
    async with MotoService('batch') as svc:
        yield svc.endpoint_url


@pytest.fixture
async def lambda_server():
    async with MotoService('lambda') as svc:
        yield svc.endpoint_url


@pytest.fixture
async def iam_server():
    async with MotoService('iam') as svc:
        yield svc.endpoint_url


@pytest.fixture
async def rds_server():
    async with MotoService('rds') as svc:
        yield svc.endpoint_url


@pytest.fixture
async def ec2_server():
    async with MotoService('ec2') as svc:
        yield svc.endpoint_url


@pytest.fixture
async def kinesis_server():

# Path: tests/moto_server.py
# _PYCHARM_HOSTED = os.environ.get('PYCHARM_HOSTED') == '1'
# _CONNECT_TIMEOUT = 90 if _PYCHARM_HOSTED else 10
# def get_free_tcp_port(release_socket: bool = False):
#     def __init__(self, service_name: str, port: int = None):
#     def endpoint_url(self):
#     def __call__(self, func):
#         async def wrapper(*args, **kwargs):
#     async def __aenter__(self):
#     async def __aexit__(self, exc_type, exc_val, exc_tb):
#     def _server_entry(self):
#     async def _start(self):
#     async def _stop(self):
# class MotoService:


# Path: tests/mock_server.py
import asyncio
import multiprocessing
import aiohttp
import aiohttp.web
import pytest
from aiohttp.web import StreamResponse
from tests.moto_server import host, MotoService, get_free_tcp_port

    async with MotoService('batch') as svc:
        yield svc.endpoint_url


@pytest.fixture
async def lambda_server():
    async with MotoService('lambda') as svc:
        yield svc.endpoint_url


@pytest.fixture
async def iam_server():
    async with MotoService('iam') as svc:
        yield svc.endpoint_url


@pytest.fixture
async def rds_server():
    async with MotoService('rds') as svc:
        yield svc.endpoint_url


@pytest.fixture
async def ec2_server():
    async with MotoService('ec2') as svc:
        yield svc.endpoint_url


@pytest.fixture
async def kinesis_server():

    async with MotoService('kinesis') as svc: