import asyncio
import aiohttp

from .consumer import Consumer