Skip to content

Commit 710e268

Browse files
committed
style: fix formatting
1 parent 1b09438 commit 710e268

File tree

2 files changed

+16
-16
lines changed

2 files changed

+16
-16
lines changed

util/src/main/java/io/kubernetes/client/util/WaitUtils.java

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -41,20 +41,20 @@
4141
* Duration.ofMinutes(5),
4242
* Duration.ofSeconds(1)
4343
* );
44-
*
44+
*
4545
* // Wait for a custom condition
4646
* V1Pod runningPod = WaitUtils.waitUntilCondition(
4747
* () -> coreV1Api.readNamespacedPod("my-pod", "default").execute(),
4848
* pod -> "Running".equals(pod.getStatus().getPhase()),
4949
* Duration.ofMinutes(5),
5050
* Duration.ofSeconds(1)
5151
* );
52-
*
52+
*
5353
* // Using GenericKubernetesApi
5454
* V1Pod readyPod = WaitUtils.waitUntilReady(
55-
* podApi,
56-
* "default",
57-
* "my-pod",
55+
* podApi,
56+
* "default",
57+
* "my-pod",
5858
* Duration.ofMinutes(5)
5959
* );
6060
* }</pre>
@@ -253,8 +253,8 @@ public static <T extends KubernetesObject, L extends io.kubernetes.client.common
253253

254254
return waitUntilCondition(
255255
() -> {
256-
KubernetesApiResponse<T> response = namespace != null
257-
? api.get(namespace, name)
256+
KubernetesApiResponse<T> response = namespace != null
257+
? api.get(namespace, name)
258258
: api.get(name);
259259
return response.isSuccess() ? response.getObject() : null;
260260
},
@@ -287,8 +287,8 @@ public static <T extends KubernetesObject, L extends io.kubernetes.client.common
287287

288288
return waitUntilCondition(
289289
() -> {
290-
KubernetesApiResponse<T> response = namespace != null
291-
? api.get(namespace, name)
290+
KubernetesApiResponse<T> response = namespace != null
291+
? api.get(namespace, name)
292292
: api.get(name);
293293
return response.isSuccess() ? response.getObject() : null;
294294
},
@@ -350,7 +350,7 @@ public static <T extends KubernetesObject> CompletableFuture<T> waitUntilConditi
350350
Duration pollInterval) {
351351

352352
CompletableFuture<T> result = new CompletableFuture<>();
353-
353+
354354
CompletableFuture.runAsync(() -> {
355355
try {
356356
T resource = waitUntilCondition(resourceSupplier, condition, timeout, pollInterval);

util/src/test/java/io/kubernetes/client/util/WaitUtilsTest.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ void waitUntilReady_timesOut_throwsTimeoutException() {
6363
V1Pod notReadyPod = createNotReadyPod();
6464
Supplier<V1Pod> supplier = () -> notReadyPod;
6565

66-
assertThatThrownBy(() ->
66+
assertThatThrownBy(() ->
6767
WaitUtils.waitUntilReady(supplier, Duration.ofMillis(200), Duration.ofMillis(50)))
6868
.isInstanceOf(TimeoutException.class);
6969
}
@@ -114,7 +114,7 @@ void waitUntilCondition_nullResource_keepsPolling() {
114114
return null;
115115
};
116116

117-
assertThatThrownBy(() ->
117+
assertThatThrownBy(() ->
118118
WaitUtils.waitUntilCondition(
119119
supplier,
120120
p -> true,
@@ -182,7 +182,7 @@ void waitUntilDeleted_supplierThrows_treatsAsDeleted() throws Exception {
182182
void waitUntilDeleted_notDeleted_timesOut() {
183183
Supplier<V1Pod> supplier = () -> createReadyPod();
184184

185-
assertThatThrownBy(() ->
185+
assertThatThrownBy(() ->
186186
WaitUtils.waitUntilDeleted(supplier, Duration.ofMillis(200), Duration.ofMillis(50)))
187187
.isInstanceOf(TimeoutException.class);
188188
}
@@ -217,23 +217,23 @@ void waitUntilConditionAsync_returnsCompletableFuture() throws Exception {
217217

218218
@Test
219219
void waitUntilCondition_nullSupplier_throwsNullPointerException() {
220-
assertThatThrownBy(() ->
220+
assertThatThrownBy(() ->
221221
WaitUtils.waitUntilCondition(null, p -> true, Duration.ofSeconds(1), Duration.ofMillis(100)))
222222
.isInstanceOf(NullPointerException.class)
223223
.hasMessageContaining("resourceSupplier");
224224
}
225225

226226
@Test
227227
void waitUntilCondition_nullCondition_throwsNullPointerException() {
228-
assertThatThrownBy(() ->
228+
assertThatThrownBy(() ->
229229
WaitUtils.waitUntilCondition(() -> createReadyPod(), null, Duration.ofSeconds(1), Duration.ofMillis(100)))
230230
.isInstanceOf(NullPointerException.class)
231231
.hasMessageContaining("condition");
232232
}
233233

234234
@Test
235235
void waitUntilCondition_nullTimeout_throwsNullPointerException() {
236-
assertThatThrownBy(() ->
236+
assertThatThrownBy(() ->
237237
WaitUtils.waitUntilCondition(() -> createReadyPod(), p -> true, null, Duration.ofMillis(100)))
238238
.isInstanceOf(NullPointerException.class)
239239
.hasMessageContaining("timeout");

0 commit comments

Comments
 (0)