def _flush(self):
        transfer_count = len(self._request_list)

        if transfer_count > 0:
            assert transfer_count <= COMMANDS_PER_DAP_TRANSFER
            try:
                resp = self._protocol.transfer(
                        transfer_count, self._request_list, self._data_list)
                self._response_list.extend(resp)
            except TransferError:
                # Dump any pending commands
                self._request_list = []
                self._data_list = []
                self._handler_list = []
                # Dump any data read
                self._response_list = []
                # Invalidate cached registers
                self._csw = -1
                self._dp_select = -1
                # Clear error
                self.clearStickyErr()
                raise

            self._request_list = []
            self._data_list = []
Replies to create instant node requests return the created node.
dataset/ETHPy150Open geky/pyDAPLink/pyDAPLink/daplink/core.py/DAPLinkCore._flush--crossover with--dataset/ETHPy150Open ralphm/wokkel/wokkel/test/test_pubsub.py/PubSubServiceTest.test_on_createInstant