@Test public void testCheckTypes() { assertThat(rxJava2TimeLimiterAspectExt.canHandleReturnType(Flowable.class)).isTrue(); assertThat(rxJava2TimeLimiterAspectExt.canHandleReturnType(Single.class)).isTrue(); assertThat(rxJava2TimeLimiterAspectExt.canHandleReturnType(Observable.class)).isTrue(); assertThat(rxJava2TimeLimiterAspectExt.canHandleReturnType(Completable.class)).isTrue(); assertThat(rxJava2TimeLimiterAspectExt.canHandleReturnType(Maybe.class)).isTrue(); }
@Override public boolean canHandleReturnType(Class<?> returnType) { return rxSupportedTypes.stream().anyMatch(classType -> classType.isAssignableFrom(returnType)); }
RxJava2TimeLimiterAspectExt implements TimeLimiterAspectExt { @Override public boolean canHandleReturnType(Class<?> returnType) { return rxSupportedTypes.stream().anyMatch(classType -> classType.isAssignableFrom(returnType)); } }
RxJava2TimeLimiterAspectExt implements TimeLimiterAspectExt { @Override public boolean canHandleReturnType(Class<?> returnType) { return rxSupportedTypes.stream().anyMatch(classType -> classType.isAssignableFrom(returnType)); }  }
RxJava2TimeLimiterAspectExt implements TimeLimiterAspectExt { @Override public boolean canHandleReturnType(Class<?> returnType) { return rxSupportedTypes.stream().anyMatch(classType -> classType.isAssignableFrom(returnType)); }  @Override boolean canHandleReturnType(Class<?> returnType); @Override Object handle(ProceedingJoinPoint proceedingJoinPoint, TimeLimiter timeLimiter, String methodName); }
RxJava2TimeLimiterAspectExt implements TimeLimiterAspectExt { @Override public boolean canHandleReturnType(Class<?> returnType) { return rxSupportedTypes.stream().anyMatch(classType -> classType.isAssignableFrom(returnType)); }  @Override boolean canHandleReturnType(Class<?> returnType); @Override Object handle(ProceedingJoinPoint proceedingJoinPoint, TimeLimiter timeLimiter, String methodName);  }