flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientTest.java
/**
	 * Validates the result of a GET operation by comparing the data from the retrieved input stream to the content of
	 * the expected input stream.
	 *
	 * @param actualInputStream
	 *        the input stream returned from the GET operation (will be closed by this method)
	 * @param expectedInputStream
	 *        the input stream to compare the input stream's data to
	 * @throws IOException
	 *         thrown if an I/O error occurs while reading any input stream
	 */
Validates the result of a GET operation by comparing the data from the retrieved input stream to the content of
the expected input stream.

@param actualInputStream
the input stream returned from the GET operation (will be closed by this method)
@param expectedInputStream
the input stream to compare the input stream's data to
@throws IOException
thrown if an I/O error occurs while reading any input stream
Validates the result of a GET operation by comparing the data from the retrieved input stream to the content of the expected input stream . @param actualInputStream the input stream returned from the GET operation ( will be closed by this method ) @param expectedInputStream the input stream to compare the input stream ' s data to @throws IOException thrown if an I / O error occurs while reading any input stream
static void validateGetAndClose(InputStream actualInputStream, InputStream expectedInputStream)
			throws IOException {
		try {
			while (true) {
				final int r1 = actualInputStream.read();
				final int r2 = expectedInputStream.read();
				assertEquals(r2, r1);
				if (r1 < 0) {
					break;
				}
			}
		} finally {
			actualInputStream.close();
			expectedInputStream.close();
		}
	}
static void validateGetAndClose ( InputStream actualInputStream , InputStream expectedInputStream ) throws IOException { try { while ( true ) { final int r1 = actualInputStream . read ( ) ; final int r2 = expectedInputStream . read ( ) ; assertEquals ( r2 , r1 ) ; if ( r1 < 0 ) { break ; } } } finally { actualInputStream . close ( ) ; expectedInputStream . close ( ) ; } }
Validates the result of a GET operation by comparing the data from the retrieved input stream to the content of
 the expected input stream.
Validates the result of a GET operation by comparing the data from the retrieved input stream to the content of the expected input stream .