@Override
    public void loadDocOnUpstreamChanged(final List<DiscoverySyncData> discoverySyncDataList, final DataEventTypeEnum eventType) {
        if (Objects.nonNull(eventType) && (eventType == DataEventTypeEnum.CREATE || eventType == DataEventTypeEnum.UPDATE)) {
            List<UpstreamInstance> serviceList = this.getLastUpdateInstanceList(discoverySyncDataList);
            if (CollectionUtils.isEmpty(serviceList)) {
                LOG.info("load api document, no service registered.");
                return;
            }
            if (!isEnabledLoad()) {
                return;
            }
            final Set<UpstreamInstance> currentServices = new HashSet<>(serviceList);
            LOG.info("loadDocOnSelectorChanged, serviceList={}", JsonUtils.toJson(currentServices));
            pullSwaggerDocService.pullApiDocument(currentServices);
        }
    }
@Test
    public void testLoadDocOnSelectorChanged() {
        DiscoverySyncData discoverySyncData = new DiscoverySyncData();
        discoverySyncData.setSelectorId("1");
        discoverySyncData.setPluginName("divide");
        discoverySyncData.setSelectorName("test");
        discoverySyncData.setUpstreamDataList(Collections.emptyList());
        List<DiscoverySyncData> changedList = new ArrayList<>();
        changedList.add(discoverySyncData);
        DataEventTypeEnum eventType = DataEventTypeEnum.acquireByName("CREATE");
        this.testLoadApiDocument();
        when(shenyuDictService.findByDictCodeName(any(), any())).thenReturn(null);
        loadServiceDocEntry.loadDocOnUpstreamChanged(changedList, eventType);
        verify(pullSwaggerDocService).pullApiDocument((Set<UpstreamInstance>) any());
    }