Skip to content

Commit d0ab04b

Browse files
committed
fix coding style
1 parent 603fe98 commit d0ab04b

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

util/src/main/java/io/kubernetes/client/informer/cache/DeltaFIFO.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -448,8 +448,11 @@ private MutablePair<DeltaType, KubernetesObject> isDuplicate(
448448
if (deletionDelta != null) {
449449
return deletionDelta;
450450
}
451-
if (d1.getLeft() != DeltaType.Deleted && d2.getLeft() != DeltaType.Deleted &&
452-
StringUtils.equals(d1.getRight().getMetadata().getResourceVersion(), d2.getRight().getMetadata().getResourceVersion())) {
451+
if (d1.getLeft() != DeltaType.Deleted
452+
&& d2.getLeft() != DeltaType.Deleted
453+
&& StringUtils.equals(
454+
d1.getRight().getMetadata().getResourceVersion(),
455+
d2.getRight().getMetadata().getResourceVersion())) {
453456
return d1;
454457
}
455458
return null;

util/src/test/java/io/kubernetes/client/informer/cache/DeltaFIFOTest.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,9 @@ public void testDeltaFIFOBasic() throws InterruptedException {
9595

9696
@Test
9797
public void testDeltaFIFODedup() {
98-
V1Pod foo1 = new V1Pod().metadata(new V1ObjectMeta().name("foo1").namespace("default").resourceVersion("ver"));
98+
V1Pod foo1 =
99+
new V1Pod()
100+
.metadata(new V1ObjectMeta().name("foo1").namespace("default").resourceVersion("ver"));
99101
Cache cache = new Cache();
100102
DeltaFIFO deltaFIFO = new DeltaFIFO(Caches::deletionHandlingMetaNamespaceKeyFunc, cache);
101103
Deque<MutablePair<DeltaFIFO.DeltaType, KubernetesObject>> deltas;

0 commit comments

Comments
 (0)