# Path: concert/config.py
# AIODEBUG = 9
# 
# Path: concert/helpers.py
# class PrioItem:
# 
#     """To be used in combination with `queue.PriorityQueue`."""
# 
#     priority: int
#     data: Any = field(compare=False)
# 
# Path: concert/quantities.py



import asyncio
import concert.config
import concurrent.futures
import functools
import queue
import logging
import time
from threading import Thread
from concert.config import AIODEBUG
from concert.helpers import PrioItem
from concert.quantities import q


LOG = logging.getLogger(__name__)
# Loop which runs in a separate thread
_TLOOP = None


async def async_generate(iterable):
    for item in iterable:

# Path: concert/config.py
# AIODEBUG = 9
# 
# Path: concert/helpers.py
# class PrioItem:
# 
#     """To be used in combination with `queue.PriorityQueue`."""
# 
#     priority: int
#     data: Any = field(compare=False)
# 
# Path: concert/quantities.py



# Path: concert/coroutines/base.py
import asyncio
import concert.config
import concurrent.futures
import functools
import queue
import logging
import time
from threading import Thread
from concert.config import AIODEBUG
from concert.helpers import PrioItem
from concert.quantities import q



LOG = logging.getLogger(__name__)
# Loop which runs in a separate thread
_TLOOP = None


async def async_generate(iterable):
    for item in iterable:

        yield item