Skip to content

Commit 369fa53

Browse files
asashourasashour
committed
Replace lambda with method reference
1 parent fa131fa commit 369fa53

File tree

49 files changed

+152
-160
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

49 files changed

+152
-160
lines changed

‎buildSrc/src/main/java/org/springframework/boot/build/antora/AntoraAsciidocAttributes.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ public class AntoraAsciidocAttributes {
5656
public AntoraAsciidocAttributes(Project project, BomExtension dependencyBom,
5757
Map<String, String> dependencyVersions) {
5858
this.version = String.valueOf(project.getVersion());
59-
this.latestVersion = Boolean.valueOf(String.valueOf(project.findProperty("latestVersion")));
59+
this.latestVersion = Boolean.parseBoolean(String.valueOf(project.findProperty("latestVersion")));
6060
this.artifactRelease = ArtifactRelease.forProject(project);
6161
this.libraries = dependencyBom.getLibraries();
6262
this.dependencyVersions = dependencyVersions;

‎buildSrc/src/main/java/org/springframework/boot/build/bom/UpgradePolicy.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,12 +35,12 @@ public enum UpgradePolicy implements BiPredicate<DependencyVersion, DependencyVe
3535
/**
3636
* Minor versions of the current major version.
3737
*/
38-
SAME_MAJOR_VERSION((candidate, current) -> candidate.isSameMajor(current)),
38+
SAME_MAJOR_VERSION(DependencyVersion::isSameMajor),
3939

4040
/**
4141
* Patch versions of the current minor version.
4242
*/
43-
SAME_MINOR_VERSION((candidate, current) -> candidate.isSameMinor(current));
43+
SAME_MINOR_VERSION(DependencyVersion::isSameMinor);
4444

4545
private final BiPredicate<DependencyVersion, DependencyVersion> delegate;
4646

‎buildSrc/src/main/java/org/springframework/boot/build/classpath/CheckClasspathForProhibitedDependencies.java

Lines changed: 7 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -70,20 +70,13 @@ public void checkForProhibitedDependencies() {
7070

7171
private boolean prohibited(ModuleVersionIdentifier id) {
7272
String group = id.getGroup();
73-
if (group.equals("javax.batch")) {
74-
return false;
75-
}
76-
if (group.equals("javax.cache")) {
77-
return false;
78-
}
79-
if (group.equals("javax.money")) {
80-
return false;
81-
}
82-
if (group.equals("org.codehaus.groovy")) {
83-
return true;
84-
}
85-
if (group.equals("org.eclipse.jetty.toolchain")) {
86-
return true;
73+
switch (group) {
74+
case "javax.batch", "javax.cache", "javax.money" -> {
75+
return false;
76+
}
77+
case "org.codehaus.groovy", "org.eclipse.jetty.toolchain" -> {
78+
return true;
79+
}
8780
}
8881
if (group.startsWith("javax")) {
8982
return true;

‎spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/quartz/QuartzEndpoint.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,7 @@
4646
import org.quartz.Trigger.TriggerState;
4747
import org.quartz.TriggerKey;
4848
import org.quartz.impl.matchers.GroupMatcher;
49+
import org.quartz.utils.Key;
4950

5051
import org.springframework.boot.actuate.endpoint.OperationResponseBody;
5152
import org.springframework.boot.actuate.endpoint.SanitizableData;
@@ -100,7 +101,7 @@ public QuartzGroupsDescriptor quartzJobGroups() throws SchedulerException {
100101
for (String groupName : this.scheduler.getJobGroupNames()) {
101102
List<String> jobs = this.scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName))
102103
.stream()
103-
.map((key) -> key.getName())
104+
.map(Key::getName)
104105
.toList();
105106
result.put(groupName, Collections.singletonMap("jobs", jobs));
106107
}
@@ -121,7 +122,7 @@ public QuartzGroupsDescriptor quartzTriggerGroups() throws SchedulerException {
121122
groupDetails.put("triggers",
122123
this.scheduler.getTriggerKeys(GroupMatcher.triggerGroupEquals(groupName))
123124
.stream()
124-
.map((key) -> key.getName())
125+
.map(Key::getName)
125126
.toList());
126127
result.put(groupName, groupDetails);
127128
}

‎spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/flyway/FlywayAutoConfiguration.java

Lines changed: 52 additions & 53 deletions
Original file line numberDiff line numberDiff line change
@@ -232,95 +232,94 @@ private void configureProperties(FluentConfiguration configuration, FlywayProper
232232
.toArray(new String[0]);
233233
configuration.locations(locations);
234234
map.from(properties.isFailOnMissingLocations())
235-
.to((failOnMissingLocations) -> configuration.failOnMissingLocations(failOnMissingLocations));
236-
map.from(properties.getEncoding()).to((encoding) -> configuration.encoding(encoding));
235+
.to(configuration::failOnMissingLocations);
236+
map.from(properties.getEncoding()).to(configuration::encoding);
237237
map.from(properties.getConnectRetries())
238-
.to((connectRetries) -> configuration.connectRetries(connectRetries));
238+
.to(configuration::connectRetries);
239239
map.from(properties.getConnectRetriesInterval())
240240
.as(Duration::getSeconds)
241241
.as(Long::intValue)
242-
.to((connectRetriesInterval) -> configuration.connectRetriesInterval(connectRetriesInterval));
242+
.to(configuration::connectRetriesInterval);
243243
map.from(properties.getLockRetryCount())
244-
.to((lockRetryCount) -> configuration.lockRetryCount(lockRetryCount));
245-
map.from(properties.getDefaultSchema()).to((schema) -> configuration.defaultSchema(schema));
244+
.to(configuration::lockRetryCount);
245+
map.from(properties.getDefaultSchema()).to(configuration::defaultSchema);
246246
map.from(properties.getSchemas())
247247
.as(StringUtils::toStringArray)
248-
.to((schemas) -> configuration.schemas(schemas));
249-
map.from(properties.isCreateSchemas()).to((createSchemas) -> configuration.createSchemas(createSchemas));
250-
map.from(properties.getTable()).to((table) -> configuration.table(table));
251-
map.from(properties.getTablespace()).to((tablespace) -> configuration.tablespace(tablespace));
248+
.to(configuration::schemas);
249+
map.from(properties.isCreateSchemas()).to(configuration::createSchemas);
250+
map.from(properties.getTable()).to(configuration::table);
251+
map.from(properties.getTablespace()).to(configuration::tablespace);
252252
map.from(properties.getBaselineDescription())
253-
.to((baselineDescription) -> configuration.baselineDescription(baselineDescription));
253+
.to(configuration::baselineDescription);
254254
map.from(properties.getBaselineVersion())
255-
.to((baselineVersion) -> configuration.baselineVersion(baselineVersion));
256-
map.from(properties.getInstalledBy()).to((installedBy) -> configuration.installedBy(installedBy));
257-
map.from(properties.getPlaceholders()).to((placeholders) -> configuration.placeholders(placeholders));
255+
.to(configuration::baselineVersion);
256+
map.from(properties.getInstalledBy()).to(configuration::installedBy);
257+
map.from(properties.getPlaceholders()).to(configuration::placeholders);
258258
map.from(properties.getPlaceholderPrefix())
259-
.to((placeholderPrefix) -> configuration.placeholderPrefix(placeholderPrefix));
259+
.to(configuration::placeholderPrefix);
260260
map.from(properties.getPlaceholderSuffix())
261-
.to((placeholderSuffix) -> configuration.placeholderSuffix(placeholderSuffix));
261+
.to(configuration::placeholderSuffix);
262262
map.from(properties.getPlaceholderSeparator())
263-
.to((placeHolderSeparator) -> configuration.placeholderSeparator(placeHolderSeparator));
263+
.to(configuration::placeholderSeparator);
264264
map.from(properties.isPlaceholderReplacement())
265-
.to((placeholderReplacement) -> configuration.placeholderReplacement(placeholderReplacement));
265+
.to(configuration::placeholderReplacement);
266266
map.from(properties.getSqlMigrationPrefix())
267-
.to((sqlMigrationPrefix) -> configuration.sqlMigrationPrefix(sqlMigrationPrefix));
267+
.to(configuration::sqlMigrationPrefix);
268268
map.from(properties.getSqlMigrationSuffixes())
269269
.as(StringUtils::toStringArray)
270-
.to((sqlMigrationSuffixes) -> configuration.sqlMigrationSuffixes(sqlMigrationSuffixes));
270+
.to(configuration::sqlMigrationSuffixes);
271271
map.from(properties.getSqlMigrationSeparator())
272-
.to((sqlMigrationSeparator) -> configuration.sqlMigrationSeparator(sqlMigrationSeparator));
272+
.to(configuration::sqlMigrationSeparator);
273273
map.from(properties.getRepeatableSqlMigrationPrefix())
274-
.to((repeatableSqlMigrationPrefix) -> configuration
275-
.repeatableSqlMigrationPrefix(repeatableSqlMigrationPrefix));
276-
map.from(properties.getTarget()).to((target) -> configuration.target(target));
274+
.to(configuration::repeatableSqlMigrationPrefix);
275+
map.from(properties.getTarget()).to(configuration::target);
277276
map.from(properties.isBaselineOnMigrate())
278-
.to((baselineOnMigrate) -> configuration.baselineOnMigrate(baselineOnMigrate));
279-
map.from(properties.isCleanDisabled()).to((cleanDisabled) -> configuration.cleanDisabled(cleanDisabled));
277+
.to(configuration::baselineOnMigrate);
278+
map.from(properties.isCleanDisabled()).to(configuration::cleanDisabled);
280279
map.from(properties.isCleanOnValidationError())
281-
.to((cleanOnValidationError) -> configuration.cleanOnValidationError(cleanOnValidationError));
282-
map.from(properties.isGroup()).to((group) -> configuration.group(group));
283-
map.from(properties.isMixed()).to((mixed) -> configuration.mixed(mixed));
284-
map.from(properties.isOutOfOrder()).to((outOfOrder) -> configuration.outOfOrder(outOfOrder));
280+
.to(configuration::cleanOnValidationError);
281+
map.from(properties.isGroup()).to(configuration::group);
282+
map.from(properties.isMixed()).to(configuration::mixed);
283+
map.from(properties.isOutOfOrder()).to(configuration::outOfOrder);
285284
map.from(properties.isSkipDefaultCallbacks())
286-
.to((skipDefaultCallbacks) -> configuration.skipDefaultCallbacks(skipDefaultCallbacks));
285+
.to(configuration::skipDefaultCallbacks);
287286
map.from(properties.isSkipDefaultResolvers())
288-
.to((skipDefaultResolvers) -> configuration.skipDefaultResolvers(skipDefaultResolvers));
287+
.to(configuration::skipDefaultResolvers);
289288
map.from(properties.isValidateMigrationNaming())
290-
.to((validateMigrationNaming) -> configuration.validateMigrationNaming(validateMigrationNaming));
289+
.to(configuration::validateMigrationNaming);
291290
map.from(properties.isValidateOnMigrate())
292-
.to((validateOnMigrate) -> configuration.validateOnMigrate(validateOnMigrate));
291+
.to(configuration::validateOnMigrate);
293292
map.from(properties.getInitSqls())
294293
.whenNot(CollectionUtils::isEmpty)
295294
.as((initSqls) -> StringUtils.collectionToDelimitedString(initSqls, "\n"))
296-
.to((initSql) -> configuration.initSql(initSql));
295+
.to(configuration::initSql);
297296
map.from(properties.getScriptPlaceholderPrefix())
298-
.to((prefix) -> configuration.scriptPlaceholderPrefix(prefix));
297+
.to(configuration::scriptPlaceholderPrefix);
299298
map.from(properties.getScriptPlaceholderSuffix())
300-
.to((suffix) -> configuration.scriptPlaceholderSuffix(suffix));
299+
.to(configuration::scriptPlaceholderSuffix);
301300
configureExecuteInTransaction(configuration, properties, map);
302-
map.from(properties::getLoggers).to((loggers) -> configuration.loggers(loggers));
301+
map.from(properties::getLoggers).to(configuration::loggers);
303302
// Flyway Teams properties
304-
map.from(properties.getBatch()).to((batch) -> configuration.batch(batch));
305-
map.from(properties.getDryRunOutput()).to((dryRunOutput) -> configuration.dryRunOutput(dryRunOutput));
303+
map.from(properties.getBatch()).to(configuration::batch);
304+
map.from(properties.getDryRunOutput()).to(configuration::dryRunOutput);
306305
map.from(properties.getErrorOverrides())
307-
.to((errorOverrides) -> configuration.errorOverrides(errorOverrides));
308-
map.from(properties.getStream()).to((stream) -> configuration.stream(stream));
306+
.to(configuration::errorOverrides);
307+
map.from(properties.getStream()).to(configuration::stream);
309308
map.from(properties.getJdbcProperties())
310309
.whenNot(Map::isEmpty)
311-
.to((jdbcProperties) -> configuration.jdbcProperties(jdbcProperties));
310+
.to(configuration::jdbcProperties);
312311
map.from(properties.getKerberosConfigFile())
313-
.to((configFile) -> configuration.kerberosConfigFile(configFile));
312+
.to(configuration::kerberosConfigFile);
314313
map.from(properties.getOutputQueryResults())
315-
.to((outputQueryResults) -> configuration.outputQueryResults(outputQueryResults));
314+
.to(configuration::outputQueryResults);
316315
map.from(properties.getSkipExecutingMigrations())
317-
.to((skipExecutingMigrations) -> configuration.skipExecutingMigrations(skipExecutingMigrations));
316+
.to(configuration::skipExecutingMigrations);
318317
map.from(properties.getIgnoreMigrationPatterns())
319318
.whenNot(List::isEmpty)
320319
.to((ignoreMigrationPatterns) -> configuration
321320
.ignoreMigrationPatterns(ignoreMigrationPatterns.toArray(new String[0])));
322321
map.from(properties.getDetectEncoding())
323-
.to((detectEncoding) -> configuration.detectEncoding(detectEncoding));
322+
.to(configuration::detectEncoding);
324323
}
325324

326325
private void configureExecuteInTransaction(FluentConfiguration configuration, FlywayProperties properties,
@@ -509,13 +508,13 @@ public void customize(FluentConfiguration configuration) {
509508
OracleConfigurationExtension.class, "Oracle");
510509
Oracle properties = this.properties.getOracle();
511510
PropertyMapper map = PropertyMapper.get().alwaysApplyingWhenNonNull();
512-
map.from(properties::getSqlplus).to(extension.via((ext, sqlplus) -> ext.setSqlplus(sqlplus)));
511+
map.from(properties::getSqlplus).to(extension.via(OracleConfigurationExtension::setSqlplus));
513512
map.from(properties::getSqlplusWarn)
514-
.to(extension.via((ext, sqlplusWarn) -> ext.setSqlplusWarn(sqlplusWarn)));
513+
.to(extension.via(OracleConfigurationExtension::setSqlplusWarn));
515514
map.from(properties::getWalletLocation)
516-
.to(extension.via((ext, walletLocation) -> ext.setWalletLocation(walletLocation)));
515+
.to(extension.via(OracleConfigurationExtension::setWalletLocation));
517516
map.from(properties::getKerberosCacheFile)
518-
.to(extension.via((ext, kerberosCacheFile) -> ext.setKerberosCacheFile(kerberosCacheFile)));
517+
.to(extension.via(OracleConfigurationExtension::setKerberosCacheFile));
519518
}
520519

521520
}
@@ -536,7 +535,7 @@ public void customize(FluentConfiguration configuration) {
536535
Postgresql properties = this.properties.getPostgresql();
537536
PropertyMapper map = PropertyMapper.get().alwaysApplyingWhenNonNull();
538537
map.from(properties::getTransactionalLock)
539-
.to(extension.via((ext, transactionalLock) -> ext.setTransactionalLock(transactionalLock)));
538+
.to(extension.via(PostgreSQLConfigurationExtension::setTransactionalLock));
540539
}
541540

542541
}
@@ -572,7 +571,7 @@ private void setKerberosLoginFile(SQLServerConfigurationExtension configuration,
572571
*/
573572
static class Extension<E extends ConfigurationExtension> {
574573

575-
private SingletonSupplier<E> extension;
574+
private final SingletonSupplier<E> extension;
576575

577576
Extension(FluentConfiguration configuration, Class<E> type, String name) {
578577
this.extension = SingletonSupplier.of(() -> {

‎spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/orm/jpa/HibernateProperties.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -148,9 +148,9 @@ public void setPhysicalStrategy(String physicalStrategy) {
148148

149149
private void applyNamingStrategies(Map<String, Object> properties) {
150150
applyNamingStrategy(properties, AvailableSettings.IMPLICIT_NAMING_STRATEGY, this.implicitStrategy,
151-
() -> SpringImplicitNamingStrategy.class.getName());
151+
SpringImplicitNamingStrategy.class::getName);
152152
applyNamingStrategy(properties, AvailableSettings.PHYSICAL_NAMING_STRATEGY, this.physicalStrategy,
153-
() -> CamelCaseToUnderscoresNamingStrategy.class.getName());
153+
CamelCaseToUnderscoresNamingStrategy.class::getName);
154154
}
155155

156156
private void applyNamingStrategy(Map<String, Object> properties, String key, Object strategy,

‎spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/graphql/security/GraphQlWebFluxSecurityAutoConfigurationTests.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@
4545
import org.springframework.security.config.annotation.method.configuration.EnableReactiveMethodSecurity;
4646
import org.springframework.security.config.annotation.web.reactive.EnableWebFluxSecurity;
4747
import org.springframework.security.config.web.server.ServerHttpSecurity;
48+
import org.springframework.security.config.web.server.ServerHttpSecurity.CsrfSpec;
4849
import org.springframework.security.core.userdetails.MapReactiveUserDetailsService;
4950
import org.springframework.security.core.userdetails.User;
5051
import org.springframework.security.core.userdetails.UserDetails;
@@ -161,7 +162,7 @@ static class SecurityConfig {
161162

162163
@Bean
163164
SecurityWebFilterChain springWebFilterChain(ServerHttpSecurity http) {
164-
return http.csrf((spec) -> spec.disable())
165+
return http.csrf(CsrfSpec::disable)
165166
// Demonstrate that method security works
166167
// Best practice to use both for defense in depth
167168
.authorizeExchange((requests) -> requests.anyExchange().permitAll())

‎spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/graphql/security/GraphQlWebMvcSecurityAutoConfigurationTests.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@
4141
import org.springframework.security.config.annotation.method.configuration.EnableMethodSecurity;
4242
import org.springframework.security.config.annotation.web.builders.HttpSecurity;
4343
import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
44+
import org.springframework.security.config.annotation.web.configurers.AbstractHttpConfigurer;
4445
import org.springframework.security.core.userdetails.User;
4546
import org.springframework.security.core.userdetails.UserDetails;
4647
import org.springframework.security.provisioning.InMemoryUserDetailsManager;
@@ -154,7 +155,7 @@ static class SecurityConfig {
154155

155156
@Bean
156157
DefaultSecurityFilterChain springWebFilterChain(HttpSecurity http) throws Exception {
157-
return http.csrf((c) -> c.disable())
158+
return http.csrf(AbstractHttpConfigurer::disable)
158159
// Demonstrate that method security works
159160
// Best practice to use both for defense in depth
160161
.authorizeHttpRequests((requests) -> requests.anyRequest().permitAll())

‎spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/logging/ConditionEvaluationReportLoggingListenerTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ void logsDebugOnContextRefresh(CapturedOutput output) {
5858
AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();
5959
this.initializer.initialize(context);
6060
context.register(Config.class);
61-
withDebugLogging(() -> context.refresh());
61+
withDebugLogging(context::refresh);
6262
assertThat(output).contains("CONDITIONS EVALUATION REPORT");
6363
}
6464

‎spring-boot-project/spring-boot-devtools/src/main/java/org/springframework/boot/devtools/autoconfigure/RemoteDevtoolsSecurityConfiguration.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import org.springframework.context.annotation.Configuration;
2424
import org.springframework.core.annotation.Order;
2525
import org.springframework.security.config.annotation.web.builders.HttpSecurity;
26+
import org.springframework.security.config.annotation.web.configurers.AbstractHttpConfigurer;
2627
import org.springframework.security.web.SecurityFilterChain;
2728
import org.springframework.security.web.util.matcher.AntPathRequestMatcher;
2829

@@ -49,7 +50,7 @@ class RemoteDevtoolsSecurityConfiguration {
4950
SecurityFilterChain devtoolsSecurityFilterChain(HttpSecurity http) throws Exception {
5051
http.securityMatcher(new AntPathRequestMatcher(this.url));
5152
http.authorizeHttpRequests((requests) -> requests.anyRequest().anonymous());
52-
http.csrf((csrf) -> csrf.disable());
53+
http.csrf(AbstractHttpConfigurer::disable);
5354
return http.build();
5455
}
5556

‎spring-boot-project/spring-boot-devtools/src/test/java/org/springframework/boot/devtools/filewatch/FileSystemWatcherTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -297,7 +297,7 @@ private void setupWatcher(long pollingInterval, long quietPeriod) {
297297
private void setupWatcher(long pollingInterval, long quietPeriod, SnapshotStateRepository snapshotStateRepository) {
298298
this.watcher = new FileSystemWatcher(false, Duration.ofMillis(pollingInterval), Duration.ofMillis(quietPeriod),
299299
snapshotStateRepository);
300-
this.watcher.addListener((changeSet) -> FileSystemWatcherTests.this.changes.add(changeSet));
300+
this.watcher.addListener(FileSystemWatcherTests.this.changes::add);
301301
}
302302

303303
private File startWithNewDirectory() {

‎spring-boot-project/spring-boot-docker-compose/src/test/java/org/springframework/boot/docker/compose/core/DefaultRunningServiceTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ void toStringReturnsServiceName() {
115115
}
116116

117117
private DefaultRunningService createRunningService(boolean psResponseHasImage) {
118-
DockerHost host = DockerHost.get("192.168.1.1", () -> Collections.emptyList());
118+
DockerHost host = DockerHost.get("192.168.1.1", Collections::emptyList);
119119
String id = "123";
120120
String name = "my-service";
121121
String image = "redis";

‎spring-boot-project/spring-boot-docker-compose/src/test/java/org/springframework/boot/docker/compose/core/DockerHostTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ class DockerHostTests {
5252

5353
private static final Function<String, String> NO_SYSTEM_ENV = (key) -> null;
5454

55-
private static final Supplier<List<DockerCliContextResponse>> NO_CONTEXT = () -> Collections.emptyList();
55+
private static final Supplier<List<DockerCliContextResponse>> NO_CONTEXT = Collections::emptyList;
5656

5757
@Test
5858
void getWhenHasHost() {

‎spring-boot-project/spring-boot-docker-compose/src/test/java/org/springframework/boot/docker/compose/lifecycle/TcpConnectServiceReadinessCheckTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,14 +58,14 @@ void setup() {
5858

5959
@Test
6060
void checkWhenServerWritesData() throws Exception {
61-
withServer((socket) -> socket.getOutputStream().write('!'), (port) -> check(port));
61+
withServer((socket) -> socket.getOutputStream().write('!'), this::check);
6262
}
6363

6464
@Test
6565
void checkWhenNoSocketOutput() throws Exception {
6666
// Simulate waiting for traffic from client to server. The sleep duration must
6767
// be longer than the read timeout of the ready check!
68-
withServer((socket) -> sleep(Duration.ofSeconds(10)), (port) -> check(port));
68+
withServer((socket) -> sleep(Duration.ofSeconds(10)), this::check);
6969
}
7070

7171
@Test

0 commit comments

Comments
 (0)