Skip to content

Commit

Permalink
fixed checkstyle violations
Browse files Browse the repository at this point in the history
  • Loading branch information
jczbsh79 committed Dec 5, 2022
1 parent 99a91f0 commit d694f48
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions sdk/src/main/java/io/dapr/client/DaprClientGrpc.java
Original file line number Diff line number Diff line change
Expand Up @@ -348,7 +348,8 @@ public <T> Mono<List<State<T>>> getBulkState(GetBulkStateRequest request, TypeRe
DaprProtos.GetBulkStateRequest envelope = builder.build();

return Mono.deferContextual(
context -> this.<DaprProtos.GetBulkStateResponse>createMono(it -> intercept(Context.of(context), asyncStub)
context -> this.<DaprProtos.GetBulkStateResponse>createMono(it ->
intercept(Context.of(context), asyncStub)
.getBulkState(envelope, it)
)
).map(
Expand Down Expand Up @@ -432,7 +433,8 @@ public Mono<Void> executeStateTransaction(ExecuteStateTransactionRequest request
DaprProtos.ExecuteStateTransactionRequest req = builder.build();

return Mono.deferContextual(
context -> this.<Empty>createMono(it -> intercept(Context.of(context), asyncStub).executeStateTransaction(req, it))
context -> this.<Empty>createMono(it ->
intercept(Context.of(context), asyncStub).executeStateTransaction(req, it))
).then();
} catch (Exception e) {
return DaprException.wrapMono(e);
Expand Down Expand Up @@ -620,7 +622,8 @@ public Mono<Map<String, String>> getSecret(GetSecretRequest request) {
DaprProtos.GetSecretRequest req = requestBuilder.build();

return Mono.deferContextual(
context -> this.<DaprProtos.GetSecretResponse>createMono(it -> intercept(Context.of(context), asyncStub).getSecret(req, it))
context -> this.<DaprProtos.GetSecretResponse>createMono(it ->
intercept(Context.of(context), asyncStub).getSecret(req, it))
).map(DaprProtos.GetSecretResponse::getDataMap);
}

Expand Down

0 comments on commit d694f48

Please sign in to comment.