Advertisement
Guest User

Untitled

a guest
Nov 16th, 2018
78
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.77 KB | None | 0 0
  1. @Override
  2. public void getAvailableForPayoutAmount(ProtoGetAvailableForPayoutAmountRequest request,
  3. StreamObserver<ProtoGetAvailableForPayoutAmountResponse> responseObserver) {
  4. ProtoGetAvailableForPayoutAmountInnerRequest.Builder innerRequestBuilder = ProtoGetAvailableForPayoutAmountInnerRequest.newBuilder();
  5.  
  6. Int32Value punterId = request.hasPunterSessionCtx() ? punterSessionHashResolver.prepareProtoPunterId(request.getPunterSessionCtx()) : null;
  7. if (punterId != null) innerRequestBuilder.setPunterId(punterId);
  8.  
  9.  
  10. ProtoGetAvailableForPayoutAmountResponse.Builder responseBuilder = ProtoGetAvailableForPayoutAmountResponse.newBuilder();
  11. if (true) {
  12. responseBuilder.setOperationResult(OK);
  13. ListenableFuture<ProtoFeedbackResponse> transform =
  14. Futures.transform(stub.getAvailableForPayoutAmount(innerRequestBuilder.build()),
  15. (ProtoGetAvailableForPayoutAmountInnerResponse innerResponse) ->
  16. {
  17. if (innerResponse != null && innerResponse.hasPayload()) {
  18. responseBuilder.setOperationResult(OK);
  19. responseBuilder.setPayload(innerResponse.getPayload());
  20. } else {
  21. responseBuilder.setOperationResult(NULL_PAYLOAD);
  22. }
  23. return responseBuilder.build();
  24. });
  25. Futures.addCallback(transform, getCallback(responseObserver));
  26. } else {
  27. responseBuilder.setOperationResult(FAIL_CHECK);
  28. responseObserver.onNext(responseBuilder.build());
  29. responseObserver.onCompleted();
  30. }
  31. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement