Class _StreamPending

python/src/cmdop/_transport.py:52–56

class _StreamPending:
    __slots__ = ("queue",)

    def __init__(self, queue: asyncio.Queue) -> None:
        self.queue = queue


_Pending = _UnaryPending | _StreamPending