class DataTypeSocketConnectionSink implements EventSink {

	@Override
	public void sink(BusData data) throws IOException {
		Ensure.not_null(data);
		m_dts.write(data);
	}

	public  DataTypeSocketConnectionSink(DataTypeSocketConnection c);

}