def __init__()

in pythonflow/pfmq/_base.py [0:0]

• 7 lines of code
• 2 McCabe index (conditional complexity)

    def __init__(self, start):
        self._thread = None
        self._cancel_address = f'inproc://{uuid.uuid4().hex}'
        self._cancel_parent = zmq.Context.instance().socket(zmq.PAIR)
        self._cancel_parent.bind(self._cancel_address)

        if start:
            self.run_async()