@Test(expected = AssertionError.class) public void cannot_sink_null_data() throws Exception { m_sc_sink.sink(null); }
@Override public void sink(BusData data) throws IOException { Ensure.not_null(data); m_dts.write(data); }
DataTypeSocketConnectionSink implements EventSink { @Override public void sink(BusData data) throws IOException { Ensure.not_null(data); m_dts.write(data); } }
DataTypeSocketConnectionSink implements EventSink { @Override public void sink(BusData data) throws IOException { Ensure.not_null(data); m_dts.write(data); } DataTypeSocketConnectionSink(DataTypeSocketConnection c); }
DataTypeSocketConnectionSink implements EventSink { @Override public void sink(BusData data) throws IOException { Ensure.not_null(data); m_dts.write(data); } DataTypeSocketConnectionSink(DataTypeSocketConnection c); @Override void sink(BusData data); }
DataTypeSocketConnectionSink implements EventSink { @Override public void sink(BusData data) throws IOException { Ensure.not_null(data); m_dts.write(data); } DataTypeSocketConnectionSink(DataTypeSocketConnection c); @Override void sink(BusData data);  }