Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Override
- public void getAvailableForPayoutAmount(ProtoGetAvailableForPayoutAmountRequest request,
- StreamObserver<ProtoGetAvailableForPayoutAmountResponse> responseObserver) {
- ProtoGetAvailableForPayoutAmountInnerRequest.Builder innerRequestBuilder = ProtoGetAvailableForPayoutAmountInnerRequest.newBuilder();
- Int32Value punterId = request.hasPunterSessionCtx() ? punterSessionHashResolver.prepareProtoPunterId(request.getPunterSessionCtx()) : null;
- if (punterId != null) innerRequestBuilder.setPunterId(punterId);
- ProtoGetAvailableForPayoutAmountResponse.Builder responseBuilder = ProtoGetAvailableForPayoutAmountResponse.newBuilder();
- if (true) {
- responseBuilder.setOperationResult(OK);
- ListenableFuture<ProtoFeedbackResponse> transform =
- Futures.transform(stub.getAvailableForPayoutAmount(innerRequestBuilder.build()),
- (ProtoGetAvailableForPayoutAmountInnerResponse innerResponse) ->
- {
- if (innerResponse != null && innerResponse.hasPayload()) {
- responseBuilder.setOperationResult(OK);
- responseBuilder.setPayload(innerResponse.getPayload());
- } else {
- responseBuilder.setOperationResult(NULL_PAYLOAD);
- }
- return responseBuilder.build();
- });
- Futures.addCallback(transform, getCallback(responseObserver));
- } else {
- responseBuilder.setOperationResult(FAIL_CHECK);
- responseObserver.onNext(responseBuilder.build());
- responseObserver.onCompleted();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement