protected void closedRegisteredResultSetsImpl()

in asterixdb-jdbc/asterix-jdbc-core/src/main/java/org/apache/asterix/jdbc/core/ADBStatement.java [498:518]

21 lines of code
6 McCabe index (conditional complexity)


    protected <T> void closedRegisteredResultSetsImpl(Queue<T> queue, Function<T, ADBResultSet> rsAccessor)
            throws SQLException {
        SQLException err = null;
        T item;
        while ((item = queue.poll()) != null) {
            ADBResultSet rs = rsAccessor.apply(item);
            if (rs != null) {
                try {
                    rs.closeImpl(false);
                } catch (SQLException e) {
                    if (err != null) {
                        e.addSuppressed(err);
                    }
                    err = e;
                }
            }
        }
        if (err != null) {
            throw err;
        }
    }