public void stream(String streamName, String stream) {
		Assert.hasText(streamName, "stream name can not be empty nor null");
		Assert.hasText(stream, "stream needs to be populated with a definition and can not be null");
		StreamUtils.stream(streamName, stream, adminServer);
		waitForXD();
		assertTrue("The stream did not deploy. ",
				waitForStreamDeployment(streamName, WAIT_TIME));
	}
Creates a stream on the XD cluster defined by the test's Artifact or Environment variables

@param streamName the name of the stream
@param stream the stream definition
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/AbstractIntegrationTest.java