def __init__(self, circuit_manager, circuit_id, conn, circuit_type,
                 path, crypt_path, max_streams=MAX_STREAMS_V3):
        self._circuit_manager = circuit_manager
        self.circuit_id = circuit_id
        self._connection = conn
        self.circuit_type = circuit_type
        self._path = path
        self._crypt_path = crypt_path
        # _read_queue handles incoming cells from the network
        self._read_queue = defer.DeferredQueue()
        self._read_task = None
        # _write_queue handles incoming data from local applications
        self._write_queue = defer.DeferredQueue()
        self._write_task = None
        self._streams = {}
        self._ctr = ctr(max_streams)
        self._max_streams = max_streams
        self._state = CState.OPEN
        # deliver window is incoming data cells
        self._deliver_window = CIRCUIT_WINDOW_THRESHOLD_INIT
        # package window is outgoing data cells
        self._package_window = CIRCUIT_WINDOW_THRESHOLD_INIT

        self._pollReadQueue()
        self._pollWriteQueue()
:param int cid: id of this circuit
dataset/ETHPy150Open nskinkel/oppy/oppy/circuit/circuit.py/Circuit.__init__