@Test
	public void testTcpSource() throws Exception {
		TcpSource tcpSource = newTcpSource();
		FileSink fileSink = newFileSink().binary(true);
		stream().create(generateStreamName(), "%s | %s", tcpSource, fileSink);

		// Following \r\n is because of CRLF deserializer
		tcpSource.ensureReady().sendBytes("Hello\r\n".getBytes("UTF-8"));
		assertThat(fileSink, eventually(hasContentsThat(equalTo("Hello"))));
	}
Tests for tcp source and sink.

@author Eric Bottard
@author Patrick Peralta
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractTcpModulesTests.java