@Test public void passesAllInputMarketDataToTimeFrameConverter() { cut.newData(someInput1); cut.newData(someInput2); verify(converter).aggregate(someInput1); verify(converter).aggregate(someInput2); }
@Override public void newData(final CIN marketData) { converter.aggregate(marketData).ifPresent(aggregated -> orig.newData(aggregated)); }
TimeFrameConvertingExpertAdvisor implements ExpertAdvisor<CIN> { @Override public void newData(final CIN marketData) { converter.aggregate(marketData).ifPresent(aggregated -> orig.newData(aggregated)); } }
TimeFrameConvertingExpertAdvisor implements ExpertAdvisor<CIN> { @Override public void newData(final CIN marketData) { converter.aggregate(marketData).ifPresent(aggregated -> orig.newData(aggregated)); } TimeFrameConvertingExpertAdvisor(final ExpertAdvisor<COUT> orig,
            final TimeFrameConverter<CIN, COUT, ITF, OTF> converter); }
TimeFrameConvertingExpertAdvisor implements ExpertAdvisor<CIN> { @Override public void newData(final CIN marketData) { converter.aggregate(marketData).ifPresent(aggregated -> orig.newData(aggregated)); } TimeFrameConvertingExpertAdvisor(final ExpertAdvisor<COUT> orig,
            final TimeFrameConverter<CIN, COUT, ITF, OTF> converter); @Override void newData(final CIN marketData); }
TimeFrameConvertingExpertAdvisor implements ExpertAdvisor<CIN> { @Override public void newData(final CIN marketData) { converter.aggregate(marketData).ifPresent(aggregated -> orig.newData(aggregated)); } TimeFrameConvertingExpertAdvisor(final ExpertAdvisor<COUT> orig,
            final TimeFrameConverter<CIN, COUT, ITF, OTF> converter); @Override void newData(final CIN marketData);  }