()
| 538 | Fiber fiber; |
| 539 | |
| 540 | @Override |
| 541 | public T call() throws Exception { |
| 542 | |
| 543 | if (first && !ended) { |
| 544 | first = false; |
| 545 | fiber = models.get(mainThread).run("" + h, h); |
| 546 | |
| 547 | if (Execution.context.get().size() > 0) |
| 548 | fiber.tag = Execution.context.get().peek(); |
| 549 | fiber.paused = () -> true; |
| 550 | |
| 551 | return (T) process.apply((T) fiber.lastReturn, fiber.runner.isDone()); |
| 552 | } |
| 553 | |
| 554 | fiber.paused = () -> { |
| 555 | fiber.paused = () -> true; |
| 556 | return false; |
| 557 | }; |
| 558 | |
| 559 | if (!ended && fiber.runner.isDone()) { |
| 560 | ended = true; |
| 561 | notifyEnded.run(); |
| 562 | } |
| 563 | |
| 564 | return (T) process.apply((T) fiber.lastReturn, fiber.runner.isDone()); |
| 565 | } |
| 566 | |
| 567 | // public void accept(Boolean willContinue) { |
| 568 | // if (!willContinue) { |
no test coverage detected