<reponame>bogdanvuk/pygears<gh_stars>100-1000
from pygears import gear, alternative
from pygears.typing import Queue, Uint, Union, bitw, trunc
from .rng import qrange
from .flatten import flatten
from .ccat import ccat
from .demux import demux


@gear(hdl={'compile': True}, enablement=b'lvl < din.lvl')
async def qdeal_impl(din: Queue, *, num,
                     lvl=b'din.lvl-1') -> b'Union[(Queue[din.data, din.lvl-1], ) * num]':

    i = Uint[bitw(num - 1)](0)

    async for (data, eot) in din:
        out_eot = eot[:lvl]

        d = data if lvl == 0 else (data, out_eot)

        yield (d, i)

        if all(out_eot):
            if i == (num - 1):
                i = 0
            else:
                i += 1


@alternative(qdeal_impl)
@gear(hdl={'compile': True}, enablement=b'lvl == din.lvl')
async def qdeal_impl_same_lvl(din: Queue, *, num, lvl=b'din.lvl-1') -> b'Union[(din, ) * num]':
    for i in range(num):
        async for (data, eot) in din:
            d = data if lvl == 0 else (data, eot)

            yield (d, trunc(i, Uint[bitw(num - 1)]))


@gear
def qdeal(din: Queue, *, num, lvl=b'din.lvl-1'):
    return din \
        | qdeal_impl(num=num, lvl=lvl) \
        | demux(use_dflt=False,
                mapping={n: n
                         for n in range(num)})


@gear
def deal(din, *, num) -> b'(din, ) * num':
    return ccat(din, qrange(num - 1, inclusive=True) | flatten) \
        | Union \
        | demux(use_dflt=False, mapping={i: i for i in range(num)})

from pygears import gear, alternative
from pygears.typing import Queue, Uint, Union, bitw, trunc
from .rng import qrange
from .flatten import flatten
from .ccat import ccat
from .demux import demux


@gear(hdl={'compile': True}, enablement=b'lvl < din.lvl')
async def qdeal_impl(din: Queue, *, num,
                     lvl=b'din.lvl-1') -> b'Union[(Queue[din.data, din.lvl-1], ) * num]':

    i = Uint[bitw(num - 1)](0)

    async for (data, eot) in din:
        out_eot = eot[:lvl]

        d = data if lvl == 0 else (data, out_eot)

        yield (d, i)

        if all(out_eot):
            if i == (num - 1):
                i = 0
            else:
                i += 1


@alternative(qdeal_impl)
@gear(hdl={'compile': True}, enablement=b'lvl == din.lvl')
async def qdeal_impl_same_lvl(din: Queue, *, num, lvl=b'din.lvl-1') -> b'Union[(din, ) * num]':
    for i in range(num):
        async for (data, eot) in din:
            d = data if lvl == 0 else (data, eot)

            yield (d, trunc(i, Uint[bitw(num - 1)]))


@gear
def qdeal(din: Queue, *, num, lvl=b'din.lvl-1'):
    return din \
        | qdeal_impl(num=num, lvl=lvl) \
        | demux(use_dflt=False,
                mapping={n: n
                         for n in range(num)})


@gear
def deal(din, *, num) -> b'(din, ) * num':
    return ccat(din, qrange(num - 1, inclusive=True) | flatten) \
        | Union \
        | demux(use_dflt=False, mapping={i: i for i in range(num)})