@Override
			public void run() {
				try {
					clientSocket = serverSocket.accept();
					StreamUtils.copy(clientSocket.getInputStream(), baos);
				}
				catch (Exception e) {
					throw new RuntimeException(e);
				}
			}
Create a socket and copy received data into a buffer

@return instance of TcpSink for fluent API chaining
@throws IOException socket processing errors
spring-xd-test-fixtures/src/main/java/org/springframework/xd/test/fixtures/TcpSink.java