@Test public void shouldWeaveAroundJoinPointAndReturnCorrectObject() throws Throwable { final Object object = flowableWeaver.weaveAroundJoinPoint(proceedingJoinPoint, mock(Logger.class)); assertThat(object).isInstanceOf(Flowable.class); }
public Object weaveAroundJoinPoint(ProceedingJoinPoint joinPoint, Logger logger) throws Throwable { final FrodoProceedingJoinPoint proceedingJoinPoint = new FrodoProceedingJoinPoint(joinPoint); final MessageManager messageManager = new MessageManager(new MessageBuilder(), logger); return new FrodoForFlowable(proceedingJoinPoint, messageManager).flowable(); }
FlowableWeaver { public Object weaveAroundJoinPoint(ProceedingJoinPoint joinPoint, Logger logger) throws Throwable { final FrodoProceedingJoinPoint proceedingJoinPoint = new FrodoProceedingJoinPoint(joinPoint); final MessageManager messageManager = new MessageManager(new MessageBuilder(), logger); return new FrodoForFlowable(proceedingJoinPoint, messageManager).flowable(); } }
FlowableWeaver { public Object weaveAroundJoinPoint(ProceedingJoinPoint joinPoint, Logger logger) throws Throwable { final FrodoProceedingJoinPoint proceedingJoinPoint = new FrodoProceedingJoinPoint(joinPoint); final MessageManager messageManager = new MessageManager(new MessageBuilder(), logger); return new FrodoForFlowable(proceedingJoinPoint, messageManager).flowable(); }  }
FlowableWeaver { public Object weaveAroundJoinPoint(ProceedingJoinPoint joinPoint, Logger logger) throws Throwable { final FrodoProceedingJoinPoint proceedingJoinPoint = new FrodoProceedingJoinPoint(joinPoint); final MessageManager messageManager = new MessageManager(new MessageBuilder(), logger); return new FrodoForFlowable(proceedingJoinPoint, messageManager).flowable(); }  static boolean methodAnnotatedWithRxLogFlowable(ProceedingJoinPoint joinPoint); Object weaveAroundJoinPoint(ProceedingJoinPoint joinPoint, Logger logger); }
FlowableWeaver { public Object weaveAroundJoinPoint(ProceedingJoinPoint joinPoint, Logger logger) throws Throwable { final FrodoProceedingJoinPoint proceedingJoinPoint = new FrodoProceedingJoinPoint(joinPoint); final MessageManager messageManager = new MessageManager(new MessageBuilder(), logger); return new FrodoForFlowable(proceedingJoinPoint, messageManager).flowable(); }  static boolean methodAnnotatedWithRxLogFlowable(ProceedingJoinPoint joinPoint); Object weaveAroundJoinPoint(ProceedingJoinPoint joinPoint, Logger logger); static final String POINTCUT; static final String ADVICE; }