stream/__init__.py

import asyncio
import multiprocessing

from stream import main

def start(*args, **kwargs):
    """
    启动流式代理服务器，兼容位置参数和关键字参数

    位置参数模式（与参考文件兼容）：
        start(queue, port, proxy)

    关键字参数模式：
        start(queue=queue, port=port, proxy=proxy)
    """
    if args:
        # 位置参数模式（与参考文件兼容）
        queue = args[0] if len(args) > 0 else None
        port = args[1] if len(args) > 1 else None
        proxy = args[2] if len(args) > 2 else None
    else:
        # 关键字参数模式
        queue = kwargs.get('queue', None)
        port = kwargs.get('port', None)
        proxy = kwargs.get('proxy', None)

    asyncio.run(main.builtin(queue=queue, port=port, proxy=proxy))