Skip to content

Commit

Permalink
fix coding style
Browse files Browse the repository at this point in the history
  • Loading branch information
fishautumn committed Sep 11, 2020
1 parent 603fe98 commit d0ab04b
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -448,8 +448,11 @@ private MutablePair<DeltaType, KubernetesObject> isDuplicate(
if (deletionDelta != null) {
return deletionDelta;
}
if (d1.getLeft() != DeltaType.Deleted && d2.getLeft() != DeltaType.Deleted &&
StringUtils.equals(d1.getRight().getMetadata().getResourceVersion(), d2.getRight().getMetadata().getResourceVersion())) {
if (d1.getLeft() != DeltaType.Deleted
&& d2.getLeft() != DeltaType.Deleted
&& StringUtils.equals(
d1.getRight().getMetadata().getResourceVersion(),
d2.getRight().getMetadata().getResourceVersion())) {
return d1;
}
return null;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,9 @@ public void testDeltaFIFOBasic() throws InterruptedException {

@Test
public void testDeltaFIFODedup() {
V1Pod foo1 = new V1Pod().metadata(new V1ObjectMeta().name("foo1").namespace("default").resourceVersion("ver"));
V1Pod foo1 =
new V1Pod()
.metadata(new V1ObjectMeta().name("foo1").namespace("default").resourceVersion("ver"));
Cache cache = new Cache();
DeltaFIFO deltaFIFO = new DeltaFIFO(Caches::deletionHandlingMetaNamespaceKeyFunc, cache);
Deque<MutablePair<DeltaFIFO.DeltaType, KubernetesObject>> deltas;
Expand Down

0 comments on commit d0ab04b

Please sign in to comment.