def METHOD_NAME(incoming_messages: Queue[BinaryMessageDefinition]) -> AsyncMock:
    """Mock can driver."""
    m = AsyncMock()
    m.__aiter__.side_effect = lambda: m
    m.__anext__.side_effect = incoming_messages.get
    return m