@Test
	public void testTCPSourceCRLF() {
		String data = UUID.randomUUID().toString();
		stream(sources.tcp() + XD_DELIMITER + sinks.file());
		sources.tcpSource().sendBytes((data + "\r\n").getBytes());
		assertValid(data, sinks.file());
		assertReceived(1);
	}
Verifies that the TCP Source that terminates with a CRLF returns the correct data.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/TcpTest.java