Skip to content

Commit

Permalink
spotless
Browse files Browse the repository at this point in the history
  • Loading branch information
jamesx-improving committed Jul 5, 2024
1 parent 167e3b1 commit 2016054
Show file tree
Hide file tree
Showing 6 changed files with 215 additions and 151 deletions.
141 changes: 74 additions & 67 deletions java/client/src/main/java/glide/api/BaseClient.java
Original file line number Diff line number Diff line change
Expand Up @@ -2752,20 +2752,19 @@ public CompletableFuture<Object[]> xautoclaim(
long minIdleTime,
@NonNull String start) {
String[] args = new String[] {key, group, consumer, Long.toString(minIdleTime), start};
return commandManager.submitNewCommand(
XAutoClaim, args, this::handleArrayResponse);
return commandManager.submitNewCommand(XAutoClaim, args, this::handleArrayResponse);
}

@Override
public CompletableFuture<Object[]> xautoclaim(
@NonNull GlideString key,
@NonNull GlideString group,
@NonNull GlideString consumer,
long minIdleTime,
@NonNull GlideString start) {
GlideString[] args = new GlideString[] {key, group, consumer, gs(Long.toString(minIdleTime)), start};
return commandManager.submitNewCommand(
XAutoClaim, args, this::handleArrayResponse);
@NonNull GlideString key,
@NonNull GlideString group,
@NonNull GlideString consumer,
long minIdleTime,
@NonNull GlideString start) {
GlideString[] args =
new GlideString[] {key, group, consumer, gs(Long.toString(minIdleTime)), start};
return commandManager.submitNewCommand(XAutoClaim, args, this::handleArrayResponse);
}

@Override
Expand All @@ -2776,26 +2775,32 @@ public CompletableFuture<Object[]> xautoclaim(
long minIdleTime,
@NonNull String start,
long count) {
String[] args = new String[] {
key, group, consumer, Long.toString(minIdleTime), start, "COUNT", Long.toString(count)
};
return commandManager.submitNewCommand(
XAutoClaim, args, this::handleArrayResponse);
String[] args =
new String[] {
key, group, consumer, Long.toString(minIdleTime), start, "COUNT", Long.toString(count)
};
return commandManager.submitNewCommand(XAutoClaim, args, this::handleArrayResponse);
}

@Override
public CompletableFuture<Object[]> xautoclaim(
@NonNull GlideString key,
@NonNull GlideString group,
@NonNull GlideString consumer,
long minIdleTime,
@NonNull GlideString start,
long count) {
GlideString[] args = new GlideString[] {
key, group, consumer, gs(Long.toString(minIdleTime)), start, gs("COUNT"), gs(Long.toString(count))
};
return commandManager.submitNewCommand(
XAutoClaim, args, this::handleArrayResponse);
@NonNull GlideString key,
@NonNull GlideString group,
@NonNull GlideString consumer,
long minIdleTime,
@NonNull GlideString start,
long count) {
GlideString[] args =
new GlideString[] {
key,
group,
consumer,
gs(Long.toString(minIdleTime)),
start,
gs("COUNT"),
gs(Long.toString(count))
};
return commandManager.submitNewCommand(XAutoClaim, args, this::handleArrayResponse);
}

@Override
Expand All @@ -2805,21 +2810,23 @@ public CompletableFuture<Object[]> xautoclaimJustId(
@NonNull String consumer,
long minIdleTime,
@NonNull String start) {
String[] args = new String[] {key, group, consumer, Long.toString(minIdleTime), start, "JUSTID"};
return commandManager.submitNewCommand(
XAutoClaim, args, this::handleArrayResponse);
String[] args =
new String[] {key, group, consumer, Long.toString(minIdleTime), start, "JUSTID"};
return commandManager.submitNewCommand(XAutoClaim, args, this::handleArrayResponse);
}

@Override
public CompletableFuture<Object[]> xautoclaimJustId(
@NonNull GlideString key,
@NonNull GlideString group,
@NonNull GlideString consumer,
long minIdleTime,
@NonNull GlideString start) {
GlideString[] args = new GlideString[] {key, group, consumer, gs(Long.toString(minIdleTime)), start, gs("JUSTID")};
return commandManager.submitNewCommand(
XAutoClaim, args, this::handleArrayResponse);
@NonNull GlideString key,
@NonNull GlideString group,
@NonNull GlideString consumer,
long minIdleTime,
@NonNull GlideString start) {
GlideString[] args =
new GlideString[] {
key, group, consumer, gs(Long.toString(minIdleTime)), start, gs("JUSTID")
};
return commandManager.submitNewCommand(XAutoClaim, args, this::handleArrayResponse);
}

@Override
Expand All @@ -2830,40 +2837,40 @@ public CompletableFuture<Object[]> xautoclaimJustId(
long minIdleTime,
@NonNull String start,
long count) {
String[] args = new String[] {
key,
group,
consumer,
Long.toString(minIdleTime),
start,
"COUNT",
Long.toString(count),
"JUSTID"
};
return commandManager.submitNewCommand(
XAutoClaim, args, this::handleArrayResponse);
String[] args =
new String[] {
key,
group,
consumer,
Long.toString(minIdleTime),
start,
"COUNT",
Long.toString(count),
"JUSTID"
};
return commandManager.submitNewCommand(XAutoClaim, args, this::handleArrayResponse);
}

@Override
public CompletableFuture<Object[]> xautoclaimJustId(
@NonNull GlideString key,
@NonNull GlideString group,
@NonNull GlideString consumer,
long minIdleTime,
@NonNull GlideString start,
long count) {
GlideString[] args = new GlideString[] {
key,
group,
consumer,
gs(Long.toString(minIdleTime)),
start,
gs("COUNT"),
gs(Long.toString(count)),
gs("JUSTID")
};
return commandManager.submitNewCommand(
XAutoClaim, args, this::handleArrayResponse);
@NonNull GlideString key,
@NonNull GlideString group,
@NonNull GlideString consumer,
long minIdleTime,
@NonNull GlideString start,
long count) {
GlideString[] args =
new GlideString[] {
key,
group,
consumer,
gs(Long.toString(minIdleTime)),
start,
gs("COUNT"),
gs(Long.toString(count)),
gs("JUSTID")
};
return commandManager.submitNewCommand(XAutoClaim, args, this::handleArrayResponse);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1437,7 +1437,11 @@ CompletableFuture<Object[]> xautoclaim(
* </pre>
*/
CompletableFuture<Object[]> xautoclaim(
GlideString key, GlideString group, GlideString consumer, long minIdleTime, GlideString start);
GlideString key,
GlideString group,
GlideString consumer,
long minIdleTime,
GlideString start);

/**
* Transfers ownership of pending stream entries that match the specified criteria.
Expand Down Expand Up @@ -1505,7 +1509,12 @@ CompletableFuture<Object[]> xautoclaim(
* </pre>
*/
CompletableFuture<Object[]> xautoclaim(
GlideString key, GlideString group, GlideString consumer, long minIdleTime, GlideString start, long count);
GlideString key,
GlideString group,
GlideString consumer,
long minIdleTime,
GlideString start,
long count);

/**
* Transfers ownership of pending stream entries that match the specified criteria. This command
Expand Down Expand Up @@ -1575,7 +1584,11 @@ CompletableFuture<Object[]> xautoclaimJustId(
* </pre>
*/
CompletableFuture<Object[]> xautoclaimJustId(
GlideString key, GlideString group, GlideString consumer, long minIdleTime, GlideString start);
GlideString key,
GlideString group,
GlideString consumer,
long minIdleTime,
GlideString start);

/**
* Transfers ownership of pending stream entries that match the specified criteria. This command
Expand Down Expand Up @@ -1647,5 +1660,10 @@ CompletableFuture<Object[]> xautoclaimJustId(
* </pre>
*/
CompletableFuture<Object[]> xautoclaimJustId(
GlideString key, GlideString group, GlideString consumer, long minIdleTime, GlideString start, long count);
GlideString key,
GlideString group,
GlideString consumer,
long minIdleTime,
GlideString start,
long count);
}
Loading

0 comments on commit 2016054

Please sign in to comment.