@Test
	public void testTcpSink() throws Exception {
		TcpSink tcpSink = newTcpSink().start();
		HttpSource httpSource = newHttpSource();

		stream().create(generateStreamName(), "%s | %s", httpSource, tcpSink);
		httpSource.ensureReady().postData("Hi there!");

		// The following CRLF is b/c of the default tcp serializer
		// NOT because of FileSink
		assertThat(tcpSink, eventually(tcpSinkReceived("Hi there!\r\n")));
	}
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