void discoverStreams()

in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/service/timebase/TimebaseStreamDiscoveryService.java [53:71]

• 16 lines of code
• 5 McCabe index (conditional complexity)

    void discoverStreams() {
        if (!isAutoDiscoveryEnabled) {
            return;
        }

        if (!timebaseConnection.isOpen()) {
            timebaseConnection.init(true);
        }

        DXTickDB connection = timebaseConnection.getConnection();
        DXTickStream[] streams = connection.listStreams();

        for (DXTickStream stream: streams) {
            if (!metaDataCacheService.contains(stream.getName())) {
                LOG.debug().append("New stream detected: ").append(stream.getName()).commit();
                eventPublisher.publishEvent(new NewStreamEvent(stream.getName()));
            }
        }
    }