Skip to content

Commit

Permalink
Spotless
Browse files Browse the repository at this point in the history
  • Loading branch information
HoustonPutman committed Jan 7, 2025
1 parent 88e0bb2 commit 33be925
Show file tree
Hide file tree
Showing 6 changed files with 9 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ public ErrorListenerPathable<byte[]> inBackground(BackgroundCallback callback, O

@Override
public ErrorListenerPathable<byte[]> inBackground(
BackgroundCallback callback, Object context, Executor executor) {
BackgroundCallback callback, Object context, Executor executor) {
return GetDataBuilderImpl.this.inBackground(callback, context, executor);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,7 @@ public ErrorListenerPathAndBytesable<Stat> inBackground(BackgroundCallback callb

@Override
public ErrorListenerPathAndBytesable<Stat> inBackground(
BackgroundCallback callback, Object context, Executor executor) {
BackgroundCallback callback, Object context, Executor executor) {
return SetDataBuilderImpl.this.inBackground(callback, context, executor);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,6 @@ public StatPathable<byte[]> decompressed() {
return this;
}


@Override
public StatPathable<byte[]> undecompressed() {
decompress = false;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -167,7 +167,9 @@ private AsyncStage<String> internalForPath(String path, byte[] data, boolean use
|| options.contains(CreateOption.createParentsAsContainers),
options.contains(CreateOption.createParentsAsContainers),
options.contains(CreateOption.doProtected),
options.contains(CreateOption.compress) ? true : options.contains(CreateOption.uncompress) ? false : client.compressionEnabled(),
options.contains(CreateOption.compress)
? true
: options.contains(CreateOption.uncompress) ? false : client.compressionEnabled(),
options.contains(CreateOption.setDataIfExists),
aclList,
stat,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -117,8 +117,9 @@ private CuratorOp internalForPath(String path, byte[] data, boolean useData) {
TransactionCreateBuilder2<CuratorOp> builder1 = (ttl > 0)
? client.transactionOp().create().withTtl(ttl)
: client.transactionOp().create();
ACLPathAndBytesable<CuratorOp> builder2 =
compressed ? builder1.compressed().withMode(createMode) : builder1.uncompressed().withMode(createMode);
ACLPathAndBytesable<CuratorOp> builder2 = compressed
? builder1.compressed().withMode(createMode)
: builder1.uncompressed().withMode(createMode);
PathAndBytesable<CuratorOp> builder3 = builder2.withACL(aclList);
try {
return useData ? builder3.forPath(path, data) : builder3.forPath(path);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -359,11 +359,7 @@ public static boolean isCompressed(Set<CreateOption> createOptions) {
public CuratorOp createOp(T model) {
return client.transactionOp()
.create()
.withOptions(
modelSpec.createMode(),
fixAclList(modelSpec.aclList()),
isCompressed(),
modelSpec.ttl())
.withOptions(modelSpec.createMode(), fixAclList(modelSpec.aclList()), isCompressed(), modelSpec.ttl())
.forPath(resolveForSet(model), modelSpec.serializer().serialize(model));
}

Expand Down

0 comments on commit 33be925

Please sign in to comment.