servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/TaskBasedAsyncCompletableOperator.java [100:114]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        private boolean shouldOffload() {
            if (!hasOffloaded) {
                try {
                    if (!shouldOffload.getAsBoolean()) {
                        return false;
                    }
                    hasOffloaded = true;
                } catch (Throwable throwable) {
                    LOGGER.warn("Offloading hint BooleanSupplier {} threw", shouldOffload, throwable);
                    // propagate the failure so that subscription is cancelled.
                    throw throwable;
                }
            }
            return true;
        }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/TaskBasedAsyncPublisherOperator.java [133:147]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        private boolean shouldOffload() {
            if (!hasOffloaded) {
                try {
                    if (!shouldOffload.getAsBoolean()) {
                        return false;
                    }
                    hasOffloaded = true;
                } catch (Throwable throwable) {
                    LOGGER.warn("Offloading hint BooleanSupplier {} threw", shouldOffload, throwable);
                    // propagate the failure so that subscription is cancelled.
                    throw throwable;
                }
            }
            return true;
        }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -