The cancel is not working on the async chain about tascalate-concurrent HOT 3 CLOSED

Read the doc about dependent() promise functionality -- you are cancelling only the the latest stage - exceptionally
For your specific case the best option is:

return CompletableTask.supplyAsync(() -> candidate, pool)
                .dependent(PromiseOrigin.ALL) //Key point
                .thenApplyAsync(CheckIp::doWork)
                .thenApplyAsync(CheckType::doWork).thenApplyAsync(CheckExclusion::doWork)
                .thenApplyAsync(AssignEntity::doWork).thenApplyAsync(DecideWmi::doWork)
                .thenApplyAsync(ObtainWmiConnection::doWork).thenApplyAsync(ObtainRegistryWmiConnection::doWork)
                .thenApplyAsync(RunCompliance::doWork).thenApplyAsync(DecideComplianceResult::doWork)
                .thenApplyAsync(CreateAlert::doWork).thenApplyAsync(ApplyFailureManager::doWork)
                .thenApplyAsync(ApplyDisconnectManager::doWork).thenApplyAsync(EnforceCompliance::doWork)
                .exceptionally(ExceptionHandlerService::handle).orTimeout(Duration.ofSeconds(3), true);

Next item, your code should cooperate with the library -- either check Thread.currentThread().isInterrupted() as in this issue or use libs that supports interruptions -- for ex., I/O streams created with Channels.newInputStream(FileChannel.open(...)) may be interrupted on read/write, but ones coming from FileInputStream are not. Same is true for different Http Connection libs (see here).

from tascalate-concurrent.

Thank you. i tried with the dependent without args and it didnt work however when i tried using the PromiseOrigin.All i got the result that i wanted

from tascalate-concurrent.

Yes, I need to document this feature. Plus what unwrap and raw do in regard to the dependent method and other decorators.

from tascalate-concurrent.