TestFXCancel.kt

fun run(): arrow.core.Tuple2<IO<ResultSet>, () -> kotlin.Unit> {

        val (localExec, cancelQuery) = fxCancellable {
            createQueryExecutionInExternalLib(…Some query…)  // returns immediately with an object that allows to abort
        }
        val (localResult, cancelResult) = fxCancellable {
            localExec.bind().executequery()  // Blocking task
        }

        return fx { localResult.bind() } toT {
            cancelQuery()
            cancelResult()
            fx { localExec.bind().abort() }.unsafeRunSync()
        }  // Here I return a function for the cancellable, that allows me to cancel all the tasks (and call the abort on the object for cleanup)
 
    }