public class AsyncRequester extends Object
Modifier and Type | Field and Description |
---|---|
protected ScheduledExecutorService |
executor |
Constructor and Description |
---|
AsyncRequester(ScheduledExecutorService executor) |
Modifier and Type | Method and Description |
---|---|
<T> com.google.common.util.concurrent.ListenableFuture<Void> |
pump(int rps,
int runtimeSeconds,
ResponseTimeMetric metric,
Callable<com.google.common.util.concurrent.ListenableFuture<T>> request) |
protected final ScheduledExecutorService executor
public AsyncRequester(ScheduledExecutorService executor)
public <T> com.google.common.util.concurrent.ListenableFuture<Void> pump(int rps, int runtimeSeconds, ResponseTimeMetric metric, Callable<com.google.common.util.concurrent.ListenableFuture<T>> request)
Copyright © 2016. All rights reserved.