@Test(dataProvider = "getSpoutThroughputMetrics")
public void testCollectSpoutThroughput(Set<MetricsItem> items, boolean expected) {

  BasicMetricsCollector collector = new BasicMetricsCollector(config, topology, items);
  assertThat(collector.collectSpoutThroughput).isEqualTo(expected);
}