@Test(expected = AssertionError.class) public void cannot_sink_null() throws Exception { BusDataQueueGroupImpl qg = new BusDataQueueGroupImpl(); BusDataQueue q = new BusDataQueue(); qg.add(q); BusDataQueueGroupSink s = new BusDataQueueGroupSink(qg); s.sink(null); }
@Override public void sink(BusData data) { Ensure.not_null(data); m_qg.add(data); }
BusDataQueueGroupSink implements EventSink { @Override public void sink(BusData data) { Ensure.not_null(data); m_qg.add(data); } }
BusDataQueueGroupSink implements EventSink { @Override public void sink(BusData data) { Ensure.not_null(data); m_qg.add(data); } BusDataQueueGroupSink(BusDataQueueGroupImpl qg); }
BusDataQueueGroupSink implements EventSink { @Override public void sink(BusData data) { Ensure.not_null(data); m_qg.add(data); } BusDataQueueGroupSink(BusDataQueueGroupImpl qg); @Override void sink(BusData data); }
BusDataQueueGroupSink implements EventSink { @Override public void sink(BusData data) { Ensure.not_null(data); m_qg.add(data); } BusDataQueueGroupSink(BusDataQueueGroupImpl qg); @Override void sink(BusData data);  }