RxJava2CircuitBreakerAspectExt implements CircuitBreakerAspectExt { @SuppressWarnings("unchecked") @Override public boolean canHandleReturnType(Class returnType) { return rxSupportedTypes.stream() .anyMatch(classType -> classType.isAssignableFrom(returnType)); }  @SuppressWarnings("unchecked") @Override boolean canHandleReturnType(Class returnType); @SuppressWarnings("unchecked") @Override Object handle(ProceedingJoinPoint proceedingJoinPoint, CircuitBreaker circuitBreaker,
        String methodName);  }
@Test public void testCheckTypes() { assertThat(rxJava2CircuitBreakerAspectExt.canHandleReturnType(Flowable.class)).isTrue(); assertThat(rxJava2CircuitBreakerAspectExt.canHandleReturnType(Single.class)).isTrue(); }