String prefix = file.getName().split("-" + infoFileSuffix + ".*")[0];
                    return group.contains(prefix) || name.contains(prefix);
                })
                .findFirst()
            : java.util.Optional.empty();

        return license.orElseThrow(
            () -> new IllegalStateException(
                "Unable to find "
                    + infoFileSuffix

                return result;
            } else {
                session.getAllProjects().stream()
                        .filter(MavenProject::isExecutionRoot)
                        .findFirst()
                        .ifPresent(buildResumptionDataRepository::removeResumptionData);
            }
        } finally {
            try {
                afterSessionEnd(session);

            try (Stream<String> lines = Files.lines(file.toPath())) {
                String packageLine = lines.filter(line -> line.startsWith("package"))
                    .findFirst()
                    .orElseThrow(() -> new IOException("Can't find package definition in file " + file));
                Matcher matcher = pattern.matcher(packageLine);
                if (matcher.find()) {

        String upstream = gitWrapper.listRemotes()
            .entrySet()
            .stream()
            .filter(entry -> entry.getValue().contains("elastic/elasticsearch"))
            .findFirst()
            .map(Map.Entry::getKey)
            .orElseThrow(
                () -> new GradleException(

            if (e.getSecond().matcher(url).matches()) {
                return e.getFirst();
            }
            return null;
        })
                .filter(StringUtil::isNotBlank)
                .findFirst()//
                .map(s -> clientFactory.getClient(s + ":" + url))//
                .orElseGet(() -> clientFactory.getClient(url));
        if (logger.isDebugEnabled()) {

            this.currentProject = ThreadLocal.withInitial(() -> first);
            this.topLevelProject = projects.stream()
                    .filter(project -> project.isExecutionRoot())
                    .findFirst()
                    .orElse(first);
        } else {
            this.currentProject = new ThreadLocal<>();
            this.topLevelProject = null;
        }
        this.projects = projects;
    }

                    .flatMap(l -> l.getDelegate().aliases().stream())
                    .filter(a -> phase.getId().equals(a.v3Phase()))
                    .findFirst()
                    .map(a -> a.v4Phase())
                    .orElse(phase.getId());

            List<MojoExecution> forkedExecutions = lifecycleMappings.get(phaseId);

                            && Objects.equals(gav.artifactId(), artifactId)
                            && (version == null || Objects.equals(gav.version(), version));
                })
                .findFirst()
                .map(Map.Entry::getKey)
                .orElse(null);
    }

     * @return corresponding channel or null
     */
    public ChannelInfo getChannelForTransport(SmbTransport transport) {
        return channels.values().stream().filter(c -> c.getTransport() == transport).findFirst().orElse(null);
    }

    /**
     * Remove a channel
     *
     * @param channel channel to remove
     */
    public void removeChannel(ChannelInfo channel) {

                if (session.getProjects() != null) {
                    pomRepositories = session.getProjects().stream()
                            .filter(p -> artifact.equals(p.getArtifact()))
                            .findFirst()
                            .map(MavenProject::getRemoteArtifactRepositories)
                            .orElseGet(() -> getRepositoriesFromModel(repositorySession, model));
                } else {