// Only count specific exceptions as failures using custom predicate
            java.util.function.Predicate<Exception> isFailure = e -> e.getMessage() != null && e.getMessage().contains("critical");

            // Non-critical failures - should NOT open circuit
            for (int i = 0; i < 5; i++) {
                try {

     * @param <T> return type
     * @param operation the operation to execute
     * @param isFailure custom failure detection
     * @return operation result
     * @throws CIFSException if circuit is open or operation fails
     */
    public <T> T executeWithCircuitBreaker(Supplier<T> operation, java.util.function.Predicate<Exception> isFailure) throws CIFSException {
        State currentState = state.get();

 */
package okhttp3

import app.cash.burst.Burst
import app.cash.burst.burstValues
import assertk.assertFailure
import assertk.assertThat
import assertk.assertions.hasMessage
import assertk.assertions.isFailure
import assertk.assertions.isFalse
import assertk.assertions.isNotSameInstanceAs
import assertk.assertions.isTrue
import java.io.FilterInputStream
import java.io.FilterOutputStream
import java.io.InputStream