Polish lambda formatting

This commit is contained in:
Phillip Webb 2017-07-24 13:18:33 -07:00
parent 7b2b8dc4a3
commit 3a01f4a6da
28 changed files with 71 additions and 73 deletions

View File

@ -51,7 +51,7 @@ public class AutoConfigurations extends Configurations implements Ordered {
.collect(Collectors.toCollection(ArrayList::new)); .collect(Collectors.toCollection(ArrayList::new));
List<String> sorted = SORTER.getInPriorityOrder(names); List<String> sorted = SORTER.getInPriorityOrder(names);
return sorted.stream() return sorted.stream()
.map(className -> ClassUtils.resolveClassName(className, null)) .map((className) -> ClassUtils.resolveClassName(className, null))
.collect(Collectors.toCollection(ArrayList::new)); .collect(Collectors.toCollection(ArrayList::new));
} }

View File

@ -136,7 +136,7 @@ public class QuartzAutoConfiguration {
public SchedulerFactoryBeanCustomizer dataSourceCustomizer( public SchedulerFactoryBeanCustomizer dataSourceCustomizer(
QuartzProperties properties, DataSource dataSource, QuartzProperties properties, DataSource dataSource,
ObjectProvider<PlatformTransactionManager> transactionManager) { ObjectProvider<PlatformTransactionManager> transactionManager) {
return schedulerFactoryBean -> { return (schedulerFactoryBean) -> {
if (properties.getJobStoreType() == JobStoreType.JDBC) { if (properties.getJobStoreType() == JobStoreType.JDBC) {
schedulerFactoryBean.setDataSource(dataSource); schedulerFactoryBean.setDataSource(dataSource);
PlatformTransactionManager txManager = transactionManager PlatformTransactionManager txManager = transactionManager

View File

@ -62,7 +62,7 @@ public class WebClientAutoConfiguration {
customizers = new ArrayList<>(customizers); customizers = new ArrayList<>(customizers);
AnnotationAwareOrderComparator.sort(customizers); AnnotationAwareOrderComparator.sort(customizers);
customizers customizers
.forEach(customizer -> customizer.customize(this.webClientBuilder)); .forEach((customizer) -> customizer.customize(this.webClientBuilder));
} }
} }

View File

@ -40,7 +40,7 @@ public class WebClientCodecCustomizer implements WebClientCustomizer {
@Override @Override
public void customize(WebClient.Builder webClientBuilder) { public void customize(WebClient.Builder webClientBuilder) {
webClientBuilder webClientBuilder
.exchangeStrategies(ExchangeStrategies.builder().codecs(codecs -> { .exchangeStrategies(ExchangeStrategies.builder().codecs((codecs) -> {
this.codecCustomizers this.codecCustomizers
.forEach((customizer) -> customizer.customize(codecs)); .forEach((customizer) -> customizer.customize(codecs));
}).build()); }).build());

View File

@ -646,7 +646,7 @@ public class DefaultServletWebServerFactoryCustomizer
private static void customizeAccessLog(JettyServletWebServerFactory factory, private static void customizeAccessLog(JettyServletWebServerFactory factory,
final ServerProperties.Jetty.Accesslog properties) { final ServerProperties.Jetty.Accesslog properties) {
factory.addServerCustomizers(server -> { factory.addServerCustomizers((server) -> {
NCSARequestLog log = new NCSARequestLog(); NCSARequestLog log = new NCSARequestLog();
if (properties.getFilename() != null) { if (properties.getFilename() != null) {
log.setFilename(properties.getFilename()); log.setFilename(properties.getFilename());

View File

@ -84,7 +84,7 @@ public class WebMvcProperties {
private boolean logResolvedException = false; private boolean logResolvedException = false;
/** /**
* Maps file extensions to media types for content negotiation, e.g. yml->text/yaml. * Maps file extensions to media types for content negotiation, e.g. yml to text/yaml.
*/ */
private Map<String, MediaType> mediaTypes = new LinkedHashMap<>(); private Map<String, MediaType> mediaTypes = new LinkedHashMap<>();

View File

@ -66,8 +66,7 @@ public class DataSourceAutoConfigurationTests {
@Test @Test
public void testDefaultDataSourceExists() throws Exception { public void testDefaultDataSourceExists() throws Exception {
this.context this.context.run((loaded) -> assertThat(loaded).hasSingleBean(DataSource.class));
.run((loaded) -> assertThat(loaded).hasSingleBean(DataSource.class));
} }
@Test @Test
@ -110,7 +109,7 @@ public class DataSourceAutoConfigurationTests {
@Test @Test
public void hikariValidatesConnectionByDefault() throws Exception { public void hikariValidatesConnectionByDefault() throws Exception {
assertDataSource(HikariDataSource.class, assertDataSource(HikariDataSource.class,
Collections.singletonList("org.apache.tomcat"), dataSource -> Collections.singletonList("org.apache.tomcat"), (dataSource) ->
// Use Connection#isValid() // Use Connection#isValid()
assertThat(dataSource.getConnectionTestQuery()).isNull()); assertThat(dataSource.getConnectionTestQuery()).isNull());
} }

View File

@ -225,7 +225,7 @@ public class ActiveMQAutoConfigurationTests {
@Bean @Bean
public ActiveMQConnectionFactoryCustomizer activeMQConnectionFactoryCustomizer() { public ActiveMQConnectionFactoryCustomizer activeMQConnectionFactoryCustomizer() {
return factory -> { return (factory) -> {
factory.setBrokerURL( factory.setBrokerURL(
"vm://localhost?useJmx=false&broker.persistent=false"); "vm://localhost?useJmx=false&broker.persistent=false");
factory.setUserName("foobar"); factory.setUserName("foobar");

View File

@ -277,7 +277,7 @@ public class ArtemisAutoConfigurationTests {
"spring.artemis.embedded.serverId=93", "spring.artemis.embedded.serverId=93",
// Do not start a specific one // Do not start a specific one
"spring.artemis.embedded.enabled=false") "spring.artemis.embedded.enabled=false")
.run(secondContext -> { .run((secondContext) -> {
DestinationChecker firstChecker = new DestinationChecker(first); DestinationChecker firstChecker = new DestinationChecker(first);
firstChecker.checkQueue("Queue1", true); firstChecker.checkQueue("Queue1", true);
DestinationChecker secondChecker = new DestinationChecker( DestinationChecker secondChecker = new DestinationChecker(

View File

@ -157,7 +157,7 @@ public class MongoReactiveAutoConfigurationTests {
@Bean @Bean
public MongoClientSettingsBuilderCustomizer customizer() { public MongoClientSettingsBuilderCustomizer customizer() {
return clientSettingsBuilder -> clientSettingsBuilder return (clientSettingsBuilder) -> clientSettingsBuilder
.applicationName("overridden-name"); .applicationName("overridden-name");
} }

View File

@ -331,7 +331,7 @@ public class QuartzAutoConfigurationTests {
@Bean @Bean
public SchedulerFactoryBeanCustomizer customizer() { public SchedulerFactoryBeanCustomizer customizer() {
return schedulerFactoryBean -> schedulerFactoryBean return (schedulerFactoryBean) -> schedulerFactoryBean
.setTaskExecutor(yetAnotherExecutor()); .setTaskExecutor(yetAnotherExecutor());
} }
@ -342,7 +342,7 @@ public class QuartzAutoConfigurationTests {
@Bean @Bean
public SchedulerFactoryBeanCustomizer customizer() { public SchedulerFactoryBeanCustomizer customizer() {
return schedulerFactoryBean -> schedulerFactoryBean return (schedulerFactoryBean) -> schedulerFactoryBean
.setSchedulerName("fooScheduler"); .setSchedulerName("fooScheduler");
} }

View File

@ -139,9 +139,9 @@ class WebTestClientContextCustomizer implements ContextCustomizer {
.getBeansOfType(CodecCustomizer.class).values(); .getBeansOfType(CodecCustomizer.class).values();
if (!CollectionUtils.isEmpty(codecCustomizers)) { if (!CollectionUtils.isEmpty(codecCustomizers)) {
clientBuilder.exchangeStrategies( clientBuilder.exchangeStrategies(
ExchangeStrategies.builder().codecs(codecs -> { ExchangeStrategies.builder().codecs((codecs) -> {
codecCustomizers.forEach( codecCustomizers.forEach((codecCustomizer) -> codecCustomizer
codecCustomizer -> codecCustomizer.customize(codecs)); .customize(codecs));
}).build()); }).build());
} }
} }

View File

@ -51,7 +51,7 @@ public abstract class AbstractApplicationContextTesterTests<T extends AbstractAp
public void runWithSystemPropertiesShouldSetAndRemoveProperties() { public void runWithSystemPropertiesShouldSetAndRemoveProperties() {
String key = "test." + UUID.randomUUID().toString(); String key = "test." + UUID.randomUUID().toString();
assertThat(System.getProperties().containsKey(key)).isFalse(); assertThat(System.getProperties().containsKey(key)).isFalse();
get().withSystemProperties(key + "=value").run(loaded -> { get().withSystemProperties(key + "=value").run((loaded) -> {
assertThat(System.getProperties()).containsEntry(key, "value"); assertThat(System.getProperties()).containsEntry(key, "value");
}); });
assertThat(System.getProperties().containsKey(key)).isFalse(); assertThat(System.getProperties().containsKey(key)).isFalse();
@ -63,7 +63,7 @@ public abstract class AbstractApplicationContextTesterTests<T extends AbstractAp
String key = "test." + UUID.randomUUID().toString(); String key = "test." + UUID.randomUUID().toString();
assertThat(System.getProperties().containsKey(key)).isFalse(); assertThat(System.getProperties().containsKey(key)).isFalse();
get().withSystemProperties(key + "=value") get().withSystemProperties(key + "=value")
.withUserConfiguration(FailingConfig.class).run(loaded -> { .withUserConfiguration(FailingConfig.class).run((loaded) -> {
assertThat(loaded).hasFailed(); assertThat(loaded).hasFailed();
}); });
assertThat(System.getProperties().containsKey(key)).isFalse(); assertThat(System.getProperties().containsKey(key)).isFalse();
@ -76,7 +76,7 @@ public abstract class AbstractApplicationContextTesterTests<T extends AbstractAp
System.setProperty(key, "value"); System.setProperty(key, "value");
try { try {
assertThat(System.getProperties().getProperty(key)).isEqualTo("value"); assertThat(System.getProperties().getProperty(key)).isEqualTo("value");
get().withSystemProperties(key + "=newValue").run(loaded -> { get().withSystemProperties(key + "=newValue").run((loaded) -> {
assertThat(System.getProperties()).containsEntry(key, "newValue"); assertThat(System.getProperties()).containsEntry(key, "newValue");
}); });
assertThat(System.getProperties().getProperty(key)).isEqualTo("value"); assertThat(System.getProperties().getProperty(key)).isEqualTo("value");
@ -93,7 +93,7 @@ public abstract class AbstractApplicationContextTesterTests<T extends AbstractAp
System.setProperty(key, "value"); System.setProperty(key, "value");
try { try {
assertThat(System.getProperties().getProperty(key)).isEqualTo("value"); assertThat(System.getProperties().getProperty(key)).isEqualTo("value");
get().withSystemProperty(key, null).run(loaded -> { get().withSystemProperty(key, null).run((loaded) -> {
assertThat(System.getProperties()).doesNotContainKey(key); assertThat(System.getProperties()).doesNotContainKey(key);
}); });
assertThat(System.getProperties().getProperty(key)).isEqualTo("value"); assertThat(System.getProperties().getProperty(key)).isEqualTo("value");
@ -106,7 +106,7 @@ public abstract class AbstractApplicationContextTesterTests<T extends AbstractAp
@Test @Test
public void runWithMultiplePropertyValuesShouldAllAllValues() throws Exception { public void runWithMultiplePropertyValuesShouldAllAllValues() throws Exception {
get().withPropertyValues("test.foo=1").withPropertyValues("test.bar=2") get().withPropertyValues("test.foo=1").withPropertyValues("test.bar=2")
.run(loaded -> { .run((loaded) -> {
Environment environment = loaded.getEnvironment(); Environment environment = loaded.getEnvironment();
assertThat(environment.getProperty("test.foo")).isEqualTo("1"); assertThat(environment.getProperty("test.foo")).isEqualTo("1");
assertThat(environment.getProperty("test.bar")).isEqualTo("2"); assertThat(environment.getProperty("test.bar")).isEqualTo("2");
@ -117,7 +117,7 @@ public abstract class AbstractApplicationContextTesterTests<T extends AbstractAp
public void runWithPropertyValuesWhenHasExistingShouldReplaceValue() public void runWithPropertyValuesWhenHasExistingShouldReplaceValue()
throws Exception { throws Exception {
get().withPropertyValues("test.foo=1").withPropertyValues("test.foo=2") get().withPropertyValues("test.foo=1").withPropertyValues("test.foo=2")
.run(loaded -> { .run((loaded) -> {
Environment environment = loaded.getEnvironment(); Environment environment = loaded.getEnvironment();
assertThat(environment.getProperty("test.foo")).isEqualTo("2"); assertThat(environment.getProperty("test.foo")).isEqualTo("2");
}); });

View File

@ -19,16 +19,17 @@ package org.springframework.boot.gradle.dsl;
import java.io.File; import java.io.File;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import org.gradle.api.Action; import javax.swing.Action;
import org.gradle.api.Project; import org.gradle.api.Project;
import org.gradle.api.plugins.BasePlugin; import org.gradle.api.plugins.BasePlugin;
import org.gradle.api.plugins.JavaPlugin; import org.gradle.api.plugins.JavaPlugin;
import org.gradle.api.plugins.JavaPluginConvention; import org.gradle.api.plugins.JavaPluginConvention;
import org.gradle.api.tasks.SourceSet; import org.gradle.api.tasks.SourceSet;
import org.gradle.api.tasks.bundling.Jar;
import org.springframework.boot.gradle.tasks.buildinfo.BuildInfo; import org.springframework.boot.gradle.tasks.buildinfo.BuildInfo;
import org.springframework.boot.gradle.tasks.buildinfo.BuildInfoProperties; import org.springframework.boot.gradle.tasks.buildinfo.BuildInfoProperties;
import org.springframework.boot.loader.tools.Layouts.Jar;
/** /**
* Entry point to Spring Boot's Gradle DSL. * Entry point to Spring Boot's Gradle DSL.
@ -78,10 +79,10 @@ public class SpringBootExtension {
BuildInfo.class); BuildInfo.class);
bootBuildInfo.setGroup(BasePlugin.BUILD_GROUP); bootBuildInfo.setGroup(BasePlugin.BUILD_GROUP);
bootBuildInfo.setDescription("Generates a META-INF/build-info.properties file."); bootBuildInfo.setDescription("Generates a META-INF/build-info.properties file.");
this.project.getPlugins().withType(JavaPlugin.class, plugin -> { this.project.getPlugins().withType(JavaPlugin.class, (plugin) -> {
this.project.getTasks().getByName(JavaPlugin.CLASSES_TASK_NAME) this.project.getTasks().getByName(JavaPlugin.CLASSES_TASK_NAME)
.dependsOn(bootBuildInfo); .dependsOn(bootBuildInfo);
this.project.afterEvaluate(evaluated -> { this.project.afterEvaluate((evaluated) -> {
BuildInfoProperties properties = bootBuildInfo.getProperties(); BuildInfoProperties properties = bootBuildInfo.getProperties();
if (properties.getArtifact() == null) { if (properties.getArtifact() == null) {
properties.setArtifact(determineArtifactBaseName()); properties.setArtifact(determineArtifactBaseName());

View File

@ -23,7 +23,6 @@ import java.io.StringWriter;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import org.gradle.api.GradleException; import org.gradle.api.GradleException;
import org.gradle.api.Plugin;
import org.gradle.api.Project; import org.gradle.api.Project;
import org.gradle.api.distribution.Distribution; import org.gradle.api.distribution.Distribution;
import org.gradle.api.distribution.DistributionContainer; import org.gradle.api.distribution.DistributionContainer;
@ -59,7 +58,7 @@ final class ApplicationPluginAction implements PluginApplicationAction {
((TemplateBasedScriptGenerator) bootStartScripts.getWindowsStartScriptGenerator()) ((TemplateBasedScriptGenerator) bootStartScripts.getWindowsStartScriptGenerator())
.setTemplate(project.getResources().getText() .setTemplate(project.getResources().getText()
.fromString(loadResource("/windowsStartScript.txt"))); .fromString(loadResource("/windowsStartScript.txt")));
project.getConfigurations().all(configuration -> { project.getConfigurations().all((configuration) -> {
if ("bootArchives".equals(configuration.getName())) { if ("bootArchives".equals(configuration.getName())) {
distribution.getContents() distribution.getContents()
.with(project.copySpec().into("lib") .with(project.copySpec().into("lib")

View File

@ -18,8 +18,6 @@ package org.springframework.boot.gradle.plugin;
import io.spring.gradle.dependencymanagement.DependencyManagementPlugin; import io.spring.gradle.dependencymanagement.DependencyManagementPlugin;
import io.spring.gradle.dependencymanagement.dsl.DependencyManagementExtension; import io.spring.gradle.dependencymanagement.dsl.DependencyManagementExtension;
import org.gradle.api.Action;
import org.gradle.api.Plugin;
import org.gradle.api.Project; import org.gradle.api.Project;
/** /**
@ -39,7 +37,7 @@ final class DependencyManagementPluginAction implements PluginApplicationAction
@Override @Override
public void execute(Project project) { public void execute(Project project) {
project.getExtensions().findByType(DependencyManagementExtension.class) project.getExtensions().findByType(DependencyManagementExtension.class)
.imports(importsHandler -> importsHandler.mavenBom(SPRING_BOOT_BOM)); .imports((importsHandler) -> importsHandler.mavenBom(SPRING_BOOT_BOM));
} }
@Override @Override

View File

@ -19,8 +19,6 @@ package org.springframework.boot.gradle.plugin;
import java.util.Collections; import java.util.Collections;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import org.gradle.api.Action;
import org.gradle.api.Plugin;
import org.gradle.api.Project; import org.gradle.api.Project;
import org.gradle.api.file.FileCollection; import org.gradle.api.file.FileCollection;
import org.gradle.api.internal.artifacts.publish.ArchivePublishArtifact; import org.gradle.api.internal.artifacts.publish.ArchivePublishArtifact;
@ -113,8 +111,8 @@ final class JavaPluginAction implements PluginApplicationAction {
} }
private void configureUtf8Encoding(Project project) { private void configureUtf8Encoding(Project project) {
project.afterEvaluate( project.afterEvaluate(evaluated -> evaluated.getTasks()
evaluated -> evaluated.getTasks().withType(JavaCompile.class, compile -> { .withType(JavaCompile.class, (compile) -> {
if (compile.getOptions().getEncoding() == null) { if (compile.getOptions().getEncoding() == null) {
compile.getOptions().setEncoding("UTF-8"); compile.getOptions().setEncoding("UTF-8");
} }

View File

@ -16,8 +16,6 @@
package org.springframework.boot.gradle.plugin; package org.springframework.boot.gradle.plugin;
import org.gradle.api.Action;
import org.gradle.api.Plugin;
import org.gradle.api.Project; import org.gradle.api.Project;
import org.gradle.api.artifacts.maven.MavenResolver; import org.gradle.api.artifacts.maven.MavenResolver;
import org.gradle.api.plugins.MavenPlugin; import org.gradle.api.plugins.MavenPlugin;
@ -43,16 +41,16 @@ final class MavenPluginAction implements PluginApplicationAction {
@Override @Override
public void execute(Project project) { public void execute(Project project) {
project.getTasks().withType(Upload.class, upload -> { project.getTasks().withType(Upload.class, (upload) -> {
if (this.uploadTaskName.equals(upload.getName())) { if (this.uploadTaskName.equals(upload.getName())) {
project.afterEvaluate(evaluated -> clearConfigurationMappings(upload)); project.afterEvaluate((evaluated) -> clearConfigurationMappings(upload));
} }
}); });
} }
private void clearConfigurationMappings(Upload upload) { private void clearConfigurationMappings(Upload upload) {
upload.getRepositories().withType(MavenResolver.class, upload.getRepositories().withType(MavenResolver.class,
resolver -> resolver.getPom().getScopeMappings().getMappings().clear()); (resolver) -> resolver.getPom().getScopeMappings().getMappings().clear());
} }
} }

View File

@ -19,10 +19,9 @@ package org.springframework.boot.gradle.plugin;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import net.bytebuddy.build.Plugin;
import org.gradle.api.GradleException; import org.gradle.api.GradleException;
import org.gradle.api.Plugin;
import org.gradle.api.Project; import org.gradle.api.Project;
import org.gradle.api.artifacts.Configuration;
import org.gradle.util.GradleVersion; import org.gradle.util.GradleVersion;
import org.springframework.boot.gradle.dsl.SpringBootExtension; import org.springframework.boot.gradle.dsl.SpringBootExtension;
@ -96,19 +95,19 @@ public class SpringBootPlugin implements Plugin<Project> {
new DependencyManagementPluginAction(), new ApplicationPluginAction()); new DependencyManagementPluginAction(), new ApplicationPluginAction());
for (PluginApplicationAction action : actions) { for (PluginApplicationAction action : actions) {
project.getPlugins().withType(action.getPluginClass(), project.getPlugins().withType(action.getPluginClass(),
plugin -> action.execute(project)); (plugin) -> action.execute(project));
} }
} }
private void unregisterUnresolvedDependenciesAnalyzer(Project project) { private void unregisterUnresolvedDependenciesAnalyzer(Project project) {
UnresolvedDependenciesAnalyzer unresolvedDependenciesAnalyzer = new UnresolvedDependenciesAnalyzer(); UnresolvedDependenciesAnalyzer unresolvedDependenciesAnalyzer = new UnresolvedDependenciesAnalyzer();
project.getConfigurations().all(configuration -> configuration.getIncoming() project.getConfigurations().all((configuration) -> configuration.getIncoming()
.afterResolve(resolvableDependencies -> unresolvedDependenciesAnalyzer .afterResolve((resolvableDependencies) -> unresolvedDependenciesAnalyzer
.analyze(configuration.getResolvedConfiguration() .analyze(configuration.getResolvedConfiguration()
.getLenientConfiguration() .getLenientConfiguration()
.getUnresolvedModuleDependencies()))); .getUnresolvedModuleDependencies())));
project.getGradle().buildFinished( project.getGradle().buildFinished(
buildResult -> unresolvedDependenciesAnalyzer.buildFinished(project)); (buildResult) -> unresolvedDependenciesAnalyzer.buildFinished(project));
} }
} }

View File

@ -42,7 +42,7 @@ class UnresolvedDependenciesAnalyzer {
void analyze(Set<UnresolvedDependency> unresolvedDependencies) { void analyze(Set<UnresolvedDependency> unresolvedDependencies) {
this.dependenciesWithNoVersion = unresolvedDependencies.stream() this.dependenciesWithNoVersion = unresolvedDependencies.stream()
.map(unresolvedDependency -> unresolvedDependency.getSelector()) .map((unresolvedDependency) -> unresolvedDependency.getSelector())
.filter(this::hasNoVersion).collect(Collectors.toSet()); .filter(this::hasNoVersion).collect(Collectors.toSet());
} }
@ -53,7 +53,7 @@ class UnresolvedDependenciesAnalyzer {
message.append("\nDuring the build, one or more dependencies that were " message.append("\nDuring the build, one or more dependencies that were "
+ "declared without a version failed to resolve:\n"); + "declared without a version failed to resolve:\n");
this.dependenciesWithNoVersion.stream() this.dependenciesWithNoVersion.stream()
.forEach(dependency -> message.append(" " + dependency + "\n")); .forEach((dependency) -> message.append(" " + dependency + "\n"));
message.append("\nDid you forget to apply the " message.append("\nDid you forget to apply the "
+ "io.spring.dependency-management plugin to the " + project.getName() + "io.spring.dependency-management plugin to the " + project.getName()
+ " project?\n"); + " project?\n");

View File

@ -23,18 +23,19 @@ import java.util.Set;
import java.util.TreeMap; import java.util.TreeMap;
import java.util.function.Function; import java.util.function.Function;
import javax.swing.text.DefaultEditorKit.CopyAction;
import io.spring.gradle.dependencymanagement.org.apache.maven.model.PatternSet;
import org.gradle.api.file.FileCopyDetails; import org.gradle.api.file.FileCopyDetails;
import org.gradle.api.file.FileTreeElement; import org.gradle.api.file.FileTreeElement;
import org.gradle.api.file.RelativePath; import org.gradle.api.file.RelativePath;
import org.gradle.api.internal.file.copy.CopyAction;
import org.gradle.api.internal.file.copy.CopyActionProcessingStream; import org.gradle.api.internal.file.copy.CopyActionProcessingStream;
import org.gradle.api.internal.file.copy.FileCopyDetailsInternal; import org.gradle.api.internal.file.copy.FileCopyDetailsInternal;
import org.gradle.api.java.archives.Attributes;
import org.gradle.api.specs.Spec; import org.gradle.api.specs.Spec;
import org.gradle.api.specs.Specs; import org.gradle.api.specs.Specs;
import org.gradle.api.tasks.WorkResult; import org.gradle.api.tasks.WorkResult;
import org.gradle.api.tasks.bundling.Jar;
import org.gradle.api.tasks.util.PatternSet; import org.springframework.boot.loader.tools.Layouts.Jar;
/** /**
* Support class for implementations of {@link BootArchive}. * Support class for implementations of {@link BootArchive}.
@ -138,10 +139,10 @@ class BootArchiveSupport {
@Override @Override
public WorkResult execute(CopyActionProcessingStream stream) { public WorkResult execute(CopyActionProcessingStream stream) {
return this.delegate.execute(action -> { return this.delegate.execute((action) -> {
Map<RelativePath, FileCopyDetailsInternal> detailsByPath = new TreeMap<>(); Map<RelativePath, FileCopyDetailsInternal> detailsByPath = new TreeMap<>();
stream.process( stream.process((details) -> detailsByPath.put(details.getRelativePath(),
details -> detailsByPath.put(details.getRelativePath(), details)); details));
detailsByPath.values().stream().forEach(action::processFile); detailsByPath.values().stream().forEach(action::processFile);
}); });
} }

View File

@ -20,14 +20,16 @@ import java.io.File;
import java.util.Collections; import java.util.Collections;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import org.gradle.api.Action; import javax.swing.Action;
import javax.swing.text.DefaultEditorKit.CopyAction;
import org.gradle.api.file.CopySpec; import org.gradle.api.file.CopySpec;
import org.gradle.api.file.FileCollection; import org.gradle.api.file.FileCollection;
import org.gradle.api.file.FileCopyDetails; import org.gradle.api.file.FileCopyDetails;
import org.gradle.api.file.FileTreeElement; import org.gradle.api.file.FileTreeElement;
import org.gradle.api.internal.file.copy.CopyAction;
import org.gradle.api.specs.Spec; import org.gradle.api.specs.Spec;
import org.gradle.api.tasks.bundling.Jar;
import org.springframework.boot.loader.tools.Layouts.Jar;
/** /**
* A custom {@link Jar} task that produces a Spring Boot executable jar. * A custom {@link Jar} task that produces a Spring Boot executable jar.
@ -55,7 +57,7 @@ public class BootJar extends Jar implements BootArchive {
} }
private Action<CopySpec> classpathFiles(Spec<File> filter) { private Action<CopySpec> classpathFiles(Spec<File> filter) {
return copySpec -> copySpec return (copySpec) -> copySpec
.from((Callable<Iterable<File>>) () -> this.classpath == null .from((Callable<Iterable<File>>) () -> this.classpath == null
? Collections.emptyList() : this.classpath.filter(filter)); ? Collections.emptyList() : this.classpath.filter(filter));

View File

@ -20,15 +20,17 @@ import java.io.File;
import java.util.Collections; import java.util.Collections;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import org.gradle.api.Action; import javax.swing.Action;
import javax.swing.text.DefaultEditorKit.CopyAction;
import org.gradle.api.Project; import org.gradle.api.Project;
import org.gradle.api.file.FileCollection; import org.gradle.api.file.FileCollection;
import org.gradle.api.file.FileCopyDetails; import org.gradle.api.file.FileCopyDetails;
import org.gradle.api.file.FileTreeElement; import org.gradle.api.file.FileTreeElement;
import org.gradle.api.internal.file.copy.CopyAction;
import org.gradle.api.specs.Spec; import org.gradle.api.specs.Spec;
import org.gradle.api.tasks.Optional; import org.gradle.api.tasks.Optional;
import org.gradle.api.tasks.bundling.War;
import org.springframework.boot.loader.tools.Layouts.War;
/** /**
* A custom {@link War} task that produces a Spring Boot executable war. * A custom {@link War} task that produces a Spring Boot executable war.
@ -50,7 +52,7 @@ public class BootWar extends War implements BootArchive {
*/ */
public BootWar() { public BootWar() {
getWebInf().into("lib-provided", getWebInf().into("lib-provided",
copySpec -> copySpec (copySpec) -> copySpec
.from((Callable<Iterable<File>>) () -> this.providedClasspath == null .from((Callable<Iterable<File>>) () -> this.providedClasspath == null
? Collections.emptyList() : this.providedClasspath)); ? Collections.emptyList() : this.providedClasspath));
} }

View File

@ -40,7 +40,7 @@ public class BootRun extends JavaExec {
public void sourceResources(SourceSet sourceSet) { public void sourceResources(SourceSet sourceSet) {
setClasspath(getProject() setClasspath(getProject()
.files(sourceSet.getResources().getSrcDirs(), getClasspath()) .files(sourceSet.getResources().getSrcDirs(), getClasspath())
.filter(file -> !file.equals(sourceSet.getOutput().getResourcesDir()))); .filter((file) -> !file.equals(sourceSet.getOutput().getResourcesDir())));
} }
@Override @Override

View File

@ -55,7 +55,7 @@ import org.springframework.util.Assert;
public abstract class Configurations { public abstract class Configurations {
private static final Comparator<Object> COMPARATOR = OrderComparator.INSTANCE private static final Comparator<Object> COMPARATOR = OrderComparator.INSTANCE
.thenComparing(o -> o.getClass().getName()); .thenComparing((other) -> other.getClass().getName());
private Set<Class<?>> classes; private Set<Class<?>> classes;
@ -117,7 +117,7 @@ public abstract class Configurations {
List<Configurations> orderedConfigurations = new ArrayList<>(configurations); List<Configurations> orderedConfigurations = new ArrayList<>(configurations);
orderedConfigurations.sort(COMPARATOR); orderedConfigurations.sort(COMPARATOR);
List<Configurations> collated = collate(orderedConfigurations); List<Configurations> collated = collate(orderedConfigurations);
return collated.stream().flatMap(c -> c.getClasses().stream()) return collated.stream().flatMap((c) -> c.getClasses().stream())
.collect(Collectors.toCollection(LinkedHashSet::new)) .collect(Collectors.toCollection(LinkedHashSet::new))
.toArray(new Class<?>[0]); .toArray(new Class<?>[0]);
} }

View File

@ -109,7 +109,7 @@ public class NettyWebServer implements WebServer {
this.nettyContext.shutdown(); this.nettyContext.shutdown();
// temporary fix for gh-9146 // temporary fix for gh-9146
this.nettyContext.getContext().onClose() this.nettyContext.getContext().onClose()
.doOnSuccess(aVoid -> HttpResources.reset()).block(); .doOnSuccess((o) -> HttpResources.reset()).block();
this.nettyContext = null; this.nettyContext = null;
} }
} }

View File

@ -112,9 +112,10 @@ public class NoUnboundElementsBindHandlerTests {
source.put("example.other", "baz"); source.put("example.other", "baz");
this.sources.add(source); this.sources.add(source);
this.binder = new Binder(this.sources); this.binder = new Binder(this.sources);
NoUnboundElementsBindHandler handler = new NoUnboundElementsBindHandler(BindHandler.DEFAULT, (configurationPropertySource -> false)); NoUnboundElementsBindHandler handler = new NoUnboundElementsBindHandler(
Example bound = this.binder.bind("example", Bindable.of(Example.class), BindHandler.DEFAULT, ((configurationPropertySource) -> false));
handler).get(); Example bound = this.binder.bind("example", Bindable.of(Example.class), handler)
.get();
assertThat(bound.getFoo()).isEqualTo("bar"); assertThat(bound.getFoo()).isEqualTo("bar");
} }

View File

@ -78,7 +78,7 @@ public abstract class AbstractReactiveWebServerFactoryTests {
Mono<String> result = getWebClient().post().uri("/test") Mono<String> result = getWebClient().post().uri("/test")
.contentType(MediaType.TEXT_PLAIN) .contentType(MediaType.TEXT_PLAIN)
.body(BodyInserters.fromObject("Hello World")).exchange() .body(BodyInserters.fromObject("Hello World")).exchange()
.flatMap(response -> response.bodyToMono(String.class)); .flatMap((response) -> response.bodyToMono(String.class));
assertThat(result.block()).isEqualTo("Hello World"); assertThat(result.block()).isEqualTo("Hello World");
this.webServer.stop(); this.webServer.stop();
Mono<ClientResponse> response = getWebClient().post().uri("/test") Mono<ClientResponse> response = getWebClient().post().uri("/test")
@ -97,7 +97,7 @@ public abstract class AbstractReactiveWebServerFactoryTests {
Mono<String> result = WebClient.create("http://localhost:" + specificPort).post() Mono<String> result = WebClient.create("http://localhost:" + specificPort).post()
.uri("/test").contentType(MediaType.TEXT_PLAIN) .uri("/test").contentType(MediaType.TEXT_PLAIN)
.body(BodyInserters.fromObject("Hello World")).exchange() .body(BodyInserters.fromObject("Hello World")).exchange()
.flatMap(response -> response.bodyToMono(String.class)); .flatMap((response) -> response.bodyToMono(String.class));
assertThat(result.block()).isEqualTo("Hello World"); assertThat(result.block()).isEqualTo("Hello World");
assertThat(this.webServer.getPort()).isEqualTo(specificPort); assertThat(this.webServer.getPort()).isEqualTo(specificPort);
} }