void processBufferedRequests()

in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BufferingNoOpRequestIndexer.java [62:74]

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

    void processBufferedRequests(RequestIndexer actualIndexer) {
        for (ActionRequest request : bufferedRequests) {
            if (request instanceof IndexRequest) {
                actualIndexer.add((IndexRequest) request);
            } else if (request instanceof DeleteRequest) {
                actualIndexer.add((DeleteRequest) request);
            } else if (request instanceof UpdateRequest) {
                actualIndexer.add((UpdateRequest) request);
            }
        }

        bufferedRequests.clear();
    }