Merge branch '3.2.x'
Closes gh-41080
This commit is contained in:
@@ -1,5 +1,5 @@
|
||||
/*
|
||||
* Copyright 2012-2023 the original author or authors.
|
||||
* Copyright 2012-2024 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
@@ -115,7 +115,7 @@ class DefaultRunningServiceTests {
|
||||
}
|
||||
|
||||
private DefaultRunningService createRunningService(boolean psResponseHasImage) {
|
||||
DockerHost host = DockerHost.get("192.168.1.1", () -> Collections.emptyList());
|
||||
DockerHost host = DockerHost.get("192.168.1.1", Collections::emptyList);
|
||||
String id = "123";
|
||||
String name = "my-service";
|
||||
String image = "redis";
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
/*
|
||||
* Copyright 2012-2023 the original author or authors.
|
||||
* Copyright 2012-2024 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
@@ -52,7 +52,7 @@ class DockerHostTests {
|
||||
|
||||
private static final Function<String, String> NO_SYSTEM_ENV = (key) -> null;
|
||||
|
||||
private static final Supplier<List<DockerCliContextResponse>> NO_CONTEXT = () -> Collections.emptyList();
|
||||
private static final Supplier<List<DockerCliContextResponse>> NO_CONTEXT = Collections::emptyList;
|
||||
|
||||
@Test
|
||||
void getWhenHasHost() {
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
/*
|
||||
* Copyright 2012-2023 the original author or authors.
|
||||
* Copyright 2012-2024 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
@@ -58,14 +58,14 @@ class TcpConnectServiceReadinessCheckTests {
|
||||
|
||||
@Test
|
||||
void checkWhenServerWritesData() throws Exception {
|
||||
withServer((socket) -> socket.getOutputStream().write('!'), (port) -> check(port));
|
||||
withServer((socket) -> socket.getOutputStream().write('!'), this::check);
|
||||
}
|
||||
|
||||
@Test
|
||||
void checkWhenNoSocketOutput() throws Exception {
|
||||
// Simulate waiting for traffic from client to server. The sleep duration must
|
||||
// be longer than the read timeout of the ready check!
|
||||
withServer((socket) -> sleep(Duration.ofSeconds(10)), (port) -> check(port));
|
||||
withServer((socket) -> sleep(Duration.ofSeconds(10)), this::check);
|
||||
}
|
||||
|
||||
@Test
|
||||
|
||||
Reference in New Issue
Block a user