final class RealCall.AsyncCall extends NamedRunnable
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.AtomicInteger |
callsPerHost |
private Callback |
responseCallback |
name
Modifier and Type | Method and Description |
---|---|
(package private) java.util.concurrent.atomic.AtomicInteger |
callsPerHost() |
protected void |
execute() |
(package private) void |
executeOn(java.util.concurrent.ExecutorService executorService)
Attempt to enqueue this async call on
executorService . |
(package private) RealCall |
get() |
(package private) java.lang.String |
host() |
(package private) Request |
request() |
(package private) void |
reuseCallsPerHostFrom(RealCall.AsyncCall other) |
run
private final Callback responseCallback
private volatile java.util.concurrent.atomic.AtomicInteger callsPerHost
AsyncCall(Callback responseCallback)
java.util.concurrent.atomic.AtomicInteger callsPerHost()
void reuseCallsPerHostFrom(RealCall.AsyncCall other)
java.lang.String host()
Request request()
RealCall get()
void executeOn(java.util.concurrent.ExecutorService executorService)
executorService
. This will attempt to clean up
if the executor has been shut down by reporting the call as failed.protected void execute()
execute
in class NamedRunnable