pdc.py 文件源码

def __init__(
        self,
        CALLBACK=None,
        BUF_SIZE=1,
        FILTER={'data'},
        WAIT_TIME=0.1,
        loop: asyncio.AbstractEventLoop()=None,
        executor: futures.Executor()=None,
        step_time=0.01,
        returnNone=False,
        count=0
        # Partially Timeout time stamps will be discarded on False
        # None will be returned for timeout data on True.
    ):
        self.WAIT_TIME = WAIT_TIME
        self.FILTER = FILTER
        self.BUF_SIZE = BUF_SIZE
        self.step_time = step_time
        self.buf_time_out = self.BUF_SIZE * self.WAIT_TIME * 2
        self._input_list = []
        self._output_list = []
        self._input_queue = asyncio.Queue()
        if loop:
            self.loop = loop
        else:
            self.loop = asyncio.get_event_loop()
        self.executor = executor
        if CALLBACK:
            self.CALLBACK = CALLBACK
        self.returnNone = returnNone
        self.count = count