chore: ensure leftovers is fully consumed before getting the next ele… · googleapis/java-storage@970242e · GitHub

googleapis / java-storage Public

• Notifications You must be signed in to change notification settings
• Fork 93
• Star 141

• Code
• Issues 2
• Pull requests 15
• Actions
• Security and quality
• Insights

Additional navigation options

Commit 970242e

Browse filesBrowse the repository at this point in the historyBrowse files

BenWhitehead

committed

chore: ensure leftovers is fully consumed before getting the next element from the queue

1 parent 27d7e3a commit 970242e
Copy full SHA for 970242e

1 file changed

+1-1Lines changed: 1 addition & 1 deletion

File tree

Expand file treeCollapse file tree

Open diff view settings

Filter options

• google-cloud-storage/src/main/java/com/google/cloud/storage
  • BaseObjectReadSessionStreamRead.java

Expand file treeCollapse file tree

Open diff view settings

Collapse file

‎google-cloud-storage/src/main/java/com/google/cloud/storage/BaseObjectReadSessionStreamRead.java‎

Copy file name to clipboardExpand all lines: google-cloud-storage/src/main/java/com/google/cloud/storage/BaseObjectReadSessionStreamRead.java

+1-1Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
@@ -393,7 +393,7 @@ public long read(ByteBuffer[] dsts, int offset, int length) throws IOException {
393	393
394	394	try {
395	395	Object poll;
396		- while ((poll = queue.poll(10, TimeUnit.MICROSECONDS)) != null) {
	396	+ while (leftovers == null && (poll = queue.poll(10, TimeUnit.MICROSECONDS)) != null) {
397	397	if (poll instanceof ChildRef) {
398	398	ChildRefHelper ref = new ChildRefHelper((ChildRef) poll);
399	399	read += ref.copy(dsts, offset, length);

0 commit comments

Comments

0 (0)