Panagiotis Triantafyllou

remove code

......@@ -1217,36 +1217,4 @@ public class WarplyManager {
}
}, null);
}
public static void getRedeemedSMHistory(final CallbackReceiver<RedeemedSMHistoryModel> receiver) {
WarpUtils.log("************* WARPLY User Redeemed History Request ********************");
WarpUtils.log("[WARP Trace] WARPLY User Redeemed History Request is active");
WarpUtils.log("**************************************************");
ApiService service = ApiClient.getRetrofitInstance().create(ApiService.class);
ListeningExecutorService executorService = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(1));
SettableFuture<RedeemedSMHistoryModel> futureUniversal = SettableFuture.create();
ListenableFuture<RedeemedSMHistoryModel> futureCoupons = getSMCouponsUniversalRetro(service, 0, futureUniversal);
ListenableFuture<List<Object>> allResultsFuture = Futures.allAsList(futureCoupons);
ListenableFuture<RedeemedSMHistoryModel> mergedResultFuture = Futures.transformAsync(allResultsFuture, results -> {
RedeemedSMHistoryModel resultCoupons = (RedeemedSMHistoryModel) results.get(0);
return executorService.submit(() -> resultCoupons);
}, executorService);
Futures.addCallback(mergedResultFuture, new FutureCallback<RedeemedSMHistoryModel>() {
@Override
public void onSuccess(RedeemedSMHistoryModel mergedResult) {
executorService.shutdownNow();
new Handler(Looper.getMainLooper()).post(() -> receiver.onSuccess(mergedResult));
}
@Override
public void onFailure(Throwable throwable) {
executorService.shutdownNow();
new Handler(Looper.getMainLooper()).post(() -> receiver.onFailure(2));
}
}, executorService);
}
}
......