Package io.vertx.rxjava3.circuitbreaker

Class FailurePolicy<T>

  • public class FailurePolicy<T>
extends Object
    A failure policy for the CircuitBreaker.

    The default policy is to consider an asynchronous result as a failure if returns true. Nevertheless, sometimes this is not good enough. For example, an HTTP Client could return a response, but with an unexpected status code.

    In this case, a custom failure policy can be configured with CircuitBreaker.failurePolicy(io.vertx.rxjava3.circuitbreaker.FailurePolicy<T>).

    NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

    • Field Detail

      • __TYPE_ARG

        public static final io.vertx.lang.rx.TypeArg<FailurePolicy> __TYPE_ARG

      • __typeArg_0

        public final io.vertx.lang.rx.TypeArg<T> __typeArg_0

    • Constructor Detail

      • FailurePolicy

        public FailurePolicy​(FailurePolicy delegate)

      • FailurePolicy

        public FailurePolicy​(Object delegate,
                     io.vertx.lang.rx.TypeArg<T> typeArg_0)

    • Method Detail

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object

      • defaultPolicy

        public static <U> FailurePolicy<U> defaultPolicy()
        The default policy, which considers an asynchronous result as a failure if returns true.
        Returns:

      • test

        public boolean test​(Single<T> future)
        Invoked by the CircuitBreaker when an operation completes.
        Parameters:
        future - a completed future
        Returns:
        true if the asynchronous result should be considered as a failure, false otherwise