@Test public void shouldBuild() throws Throwable { frodoFlowable.flowable().subscribe(subscriber); subscriber.assertValue(FlowableRule.OBSERVABLE_STREAM_VALUE); subscriber.assertNoErrors(); subscriber.assertComplete(); }
Flowable flowable() throws Throwable { messageManager.printRxComponentInfo(rxComponentInfo); final Class flowableType = joinPoint.getGenericReturnTypes().get(0); return loggableFlowable(flowableType); }
FrodoForFlowable { Flowable flowable() throws Throwable { messageManager.printRxComponentInfo(rxComponentInfo); final Class flowableType = joinPoint.getGenericReturnTypes().get(0); return loggableFlowable(flowableType); } }
FrodoForFlowable { Flowable flowable() throws Throwable { messageManager.printRxComponentInfo(rxComponentInfo); final Class flowableType = joinPoint.getGenericReturnTypes().get(0); return loggableFlowable(flowableType); } FrodoForFlowable(FrodoProceedingJoinPoint joinPoint, MessageManager messageManager); }
FrodoForFlowable { Flowable flowable() throws Throwable { messageManager.printRxComponentInfo(rxComponentInfo); final Class flowableType = joinPoint.getGenericReturnTypes().get(0); return loggableFlowable(flowableType); } FrodoForFlowable(FrodoProceedingJoinPoint joinPoint, MessageManager messageManager);  }
FrodoForFlowable { Flowable flowable() throws Throwable { messageManager.printRxComponentInfo(rxComponentInfo); final Class flowableType = joinPoint.getGenericReturnTypes().get(0); return loggableFlowable(flowableType); } FrodoForFlowable(FrodoProceedingJoinPoint joinPoint, MessageManager messageManager);   }