Function get_from_asyncio_queue

scrapy/utils/test.py:101–105

(value: _T)

def get_from_asyncio_queue(value: _T) -> Awaitable[_T]:
    q: asyncio.Queue[_T] = asyncio.Queue()
    getter = q.get()
    q.put_nowait(value)
    return getter


def get_web_client_agent_req(url: str) -> Deferred[TxResponse]:  # pragma: no cover