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