MCPcopy Index your code
hub / github.com/OpenTSDB/async / call

Method call

src/Deferred.java:1357–1370  ·  view source on GitHub ↗
(final Object arg)

Source from the content-addressed store, hash-verified

1355 }
1356
1357 public Object call(final Object arg) {
1358 if (arg instanceof Deferred) {
1359 handleContinuation((Deferred) arg, cb);
1360 } else if (!casState(PAUSED, RUNNING)) {
1361 final String cb2s = cb == null ? "null" : cb + "@" + cb.hashCode();
1362 throw new AssertionError("Tried to resume the execution of "
1363 + Deferred.this + ") although it's not in state=PAUSED."
1364 + " This occurred after the completion of " + d
1365 + " which was originally returned by callback=" + cb2s);
1366 }
1367 result = arg;
1368 runCallbacks();
1369 return arg;
1370 }
1371
1372 public String toString() {
1373 return "(continuation of Deferred@" + Deferred.super.hashCode()

Callers

nothing calls this directly

Calls 3

handleContinuationMethod · 0.80
casStateMethod · 0.80
runCallbacksMethod · 0.80

Tested by

no test coverage detected