(final Object arg)
| 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() |
nothing calls this directly
no test coverage detected