class SocketTextStreamFunction implements SourceFunction<String> {

	@Override
	public void cancel() {
		isRunning = false;
		
		// we need to close the socket as well, because the Thread.interrupt() function will
		// not wake the thread in the socketStream.read() method when blocked.
		Socket theSocket = this.currentSocket;
		if (theSocket != null) {
			IOUtils.closeSocket(theSocket);
		}
	}

	public  SocketTextStreamFunction(String hostname, int port, char delimiter, long maxNumRetries);
	public  SocketTextStreamFunction(String hostname, int port, char delimiter, long maxNumRetries, long delayBetweenRetries);

}