---

mziccard · mziccard · commit 6b61328f4344 · 2015-11-19T07:41:53.000+01:00
yaml --- r: 1961 b: refs/heads/pubsub-alpha c: bfe8924 h: refs/heads/master i: 1959: 86a1429
diff --git a/[refs] b/[refs]
@@ -3,7 +3,7 @@ refs/heads/master: 689bbb466df4b2d5d2483d6edb8ac5c7c7f7c6fa
 refs/heads/travis: e21ee7b88a5edc3f3d8c71f90c3fc32abf7e8dd6
 refs/heads/gh-pages: 4e0561bb4504bf647db669a14417b2b2c87ba45d
 refs/heads/bigquery: 762fa5830e6c398c0396177e3e7fd243bd62cfc3
-refs/heads/pubsub-alpha: 65373146e8cd827011631eb111ad4a5b52f5c2a5
+refs/heads/pubsub-alpha: bfe892428127615e2d75bcc51378c125e76ab637
 refs/heads/resource-manager: ebf4adc5ee835cd2086c4ac5b4e78d01a5a005a7
 refs/heads/update-datastore: 482954f2c5055231e5b3122ea91d2ba00ce8187c
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
diff --git a/branches/pubsub-alpha/gcloud-java-storage/src/main/java/com/google/gcloud/storage/Storage.java b/branches/pubsub-alpha/gcloud-java-storage/src/main/java/com/google/gcloud/storage/Storage.java
@@ -1408,7 +1408,11 @@ private static void checkContentType(BlobInfo blobInfo) throws IllegalArgumentEx
   /**
    * Return a channel for reading the blob's content. The blob's latest generation is read. If the
    * blob changes while reading (i.e. {@link BlobInfo#etag()} changes), subsequent calls to
-   * {@link BlobReadChannel#read(ByteBuffer)} may throw {@link StorageException}.
+   * {@code blobReadChannel.read(ByteBuffer)} may throw {@link StorageException}.
+   *
+   * <p>The {@link BlobSourceOption#generationMatch(long)} option can be provided to ensure that
+   * {@code blobReadChannel.read(ByteBuffer)} calls will throw {@link StorageException} if blob`s
+   * generation differs from the expected one.
    *
    * @throws StorageException upon failure
    */
@@ -1418,9 +1422,14 @@ private static void checkContentType(BlobInfo blobInfo) throws IllegalArgumentEx
    * Return a channel for reading the blob's content. If {@code blob.generation()} is set
    * data corresponding to that generation is read. If {@code blob.generation()} is {@code null}
    * the blob's latest generation is read. If the blob changes while reading (i.e.
-   * {@link BlobInfo#etag()} changes), subsequent calls to {@link BlobReadChannel#read(ByteBuffer)}
+   * {@link BlobInfo#etag()} changes), subsequent calls to {@code blobReadChannel.read(ByteBuffer)}
    * may throw {@link StorageException}.
    *
+   * <p>The {@link BlobSourceOption#generationMatch()} and
+   * {@link BlobSourceOption#generationMatch(long)} options can be used to ensure that
+   * {@code blobReadChannel.read(ByteBuffer)} calls will throw {@link StorageException} if the
+   * blob`s generation differs from the expected one.
+   *
    * @throws StorageException upon failure
    */
   BlobReadChannel reader(BlobId blob, BlobSourceOption... options);
diff --git a/branches/pubsub-alpha/gcloud-java-storage/src/test/java/com/google/gcloud/storage/BlobReadChannelImplTest.java b/branches/pubsub-alpha/gcloud-java-storage/src/test/java/com/google/gcloud/storage/BlobReadChannelImplTest.java
@@ -188,7 +188,6 @@ public void testReadGenerationChanged() throws IOException {
       StringBuilder messageBuilder = new StringBuilder();
       messageBuilder.append("Blob ").append(blobId).append(" was updated while reading");
       assertEquals(messageBuilder.toString(), ex.getMessage());
-      // expected
     }
   }
 
diff --git a/branches/pubsub-alpha/gcloud-java-storage/src/test/java/com/google/gcloud/storage/ITStorageTest.java b/branches/pubsub-alpha/gcloud-java-storage/src/test/java/com/google/gcloud/storage/ITStorageTest.java
@@ -759,7 +759,9 @@ public void testReadChannelFailUpdatedGeneration() throws IOException {
       reader.read(readBytes);
       fail("StorageException was expected");
     } catch(StorageException ex) {
-      // expected
+      StringBuilder messageBuilder = new StringBuilder();
+      messageBuilder.append("Blob ").append(blob.blobId()).append(" was updated while reading");
+      assertEquals(messageBuilder.toString(), ex.getMessage());
     }
     assertTrue(storage.delete(BUCKET, blobName));
   }

Original file line number	Diff line number	Diff line change
`@@ -188,7 +188,6 @@ public void testReadGenerationChanged() throws IOException {`
`188`	`188`	`StringBuilder messageBuilder = new StringBuilder();`
`189`	`189`	`messageBuilder.append("Blob ").append(blobId).append(" was updated while reading");`
`190`	`190`	`assertEquals(messageBuilder.toString(), ex.getMessage());`
`191`		`- // expected`
`192`	`191`	`}`
`193`	`192`	`}`
`194`	`193`
Original file line number	Diff line number	Diff line change
`@@ -759,7 +759,9 @@ public void testReadChannelFailUpdatedGeneration() throws IOException {`
`759`	`759`	`reader.read(readBytes);`
`760`	`760`	`fail("StorageException was expected");`
`761`	`761`	`} catch(StorageException ex) {`
`762`		`- // expected`
	`762`	`+ StringBuilder messageBuilder = new StringBuilder();`
	`763`	`+ messageBuilder.append("Blob ").append(blob.blobId()).append(" was updated while reading");`
	`764`	`+ assertEquals(messageBuilder.toString(), ex.getMessage());`
`763`	`765`	`}`
`764`	`766`	`assertTrue(storage.delete(BUCKET, blobName));`
`765`	`767`	`}`