Function buffer

tests/test_websocket_data_queue.py:17–20

(
    loop: asyncio.AbstractEventLoop, protocol: BaseProtocol
)

@pytest.fixture
def buffer(
    loop: asyncio.AbstractEventLoop, protocol: BaseProtocol
) -> WebSocketDataQueue:
    return WebSocketDataQueue(protocol, limit=1, loop=loop)


class TestWebSocketDataQueue: