return artifact -> false;
    }

    @Test
    void testEquals() {
        AndArtifactFilter filter1 = new AndArtifactFilter();

        AndArtifactFilter filter2 = new AndArtifactFilter(Arrays.asList(newSubFilter()));

        assertFalse(filter1.equals(null), "Expected " + filter1 + " to not equal " + null);
        assertTrue(filter1.equals(filter1), "Expected " + filter1 + " to equal " + filter1);

        tasks = new ArrayList<>();
    }

    public TaskSegment(boolean aggregating, Task... tasks) {
        this.aggregating = aggregating;
        this.tasks = new ArrayList<>(Arrays.asList(tasks));
    }

    @Override
    public String toString() {
        return getTasks().toString();
    }

    public List<Task> getTasks() {
        return tasks;
    }

            }
        }

        this.lifecycle = new Lifecycle(
                id,
                Collections.unmodifiableList(Arrays.asList(phases)),
                defaultBindings == null ? null : Collections.unmodifiableMap(defaultBindings));
    }

    @Override
    public Lifecycle get() {
        return lifecycle;
    }

        // Default behavior when disallowCompound is null
        assertTrue(config.isAllowCompound("AnyCommand"));

        // Set disallowCompound
        config.disallowCompound = new HashSet<>(Arrays.asList("Command1", "Command2"));

        assertFalse(config.isAllowCompound("Command1"));
        assertFalse(config.isAllowCompound("Command2"));
        assertTrue(config.isAllowCompound("Command3"));
    }

            params.getDockerContext().set(dockerContext);
            params.getMarkerFile().set(markerFile);
            params.getTags().set(Arrays.asList(tags));
            params.getPull().set(pull);
            params.getNoCache().set(noCache);
            params.getBaseImages().set(Arrays.asList(baseImages));
            params.getBuildArgs().set(buildArgs);
        });
    }

    @InputDirectory

            // sge.setLkey(disniRegion.getLocalKey());
            // sgeList.add(sge);
            //
            // sendWR.setSg_list(sgeList);
            // endpoint.postSend(Arrays.asList(sendWR)).execute().free();

            log.debug("DiSNI RDMA send completed, {} bytes", data.remaining());

        } catch (Exception e) {
            state = RdmaConnectionState.ERROR;

/**
 */
public class ExclusionSetFilter implements ArtifactFilter {
    private Set<String> excludes;

    public ExclusionSetFilter(String[] excludes) {
        this.excludes = new LinkedHashSet<>(Arrays.asList(excludes));
    }

    public ExclusionSetFilter(Set<String> excludes) {
        this.excludes = excludes;
    }

    @Override
    public boolean include(Artifact artifact) {

        assertEquals(emptyList, searchRenderData.getPageNumberList());
        assertTrue(searchRenderData.getPageNumberList().isEmpty());

        // Test with populated list
        List<String> pageNumbers = Arrays.asList("1", "2", "3", "4", "5");
        searchRenderData.setPageNumberList(pageNumbers);
        assertEquals(pageNumbers, searchRenderData.getPageNumberList());
        assertEquals(5, searchRenderData.getPageNumberList().size());

        }
    }

    // Test run method basic flow
    @Test
    public void test_run_basicFlow() throws Exception {
        final List<String> sessionIdList = Arrays.asList("session1");
        indexUpdater.setSessionIdList(sessionIdList);

        final CountDownLatch latch = new CountDownLatch(1);
        final AtomicBoolean errorOccurred = new AtomicBoolean(false);

        checkFile((line, message) -> log(line, message), max, fileText.toLinesArray());
    }

    static void checkFile(BiConsumer<Integer, String> log, int max, String... lineArray) {
        LineItr lines = new LineItr(Arrays.asList(lineArray).iterator());
        while (lines.hasNext()) {
            Matcher m = START.matcher(lines.next());
            if (m.matches()) {
                checkSnippet(log, max, lines, m.group(1), m.group(2));