From d73d1d05150d61fcc462c431e498dc4beebaccbc Mon Sep 17 00:00:00 2001
From: hai007 <hais@google.com>
Date: Tue, 21 Jan 2025 10:44:07 -0800
Subject: [PATCH] Solve BWU failing problem when Multiplex is enabled

PiperOrigin-RevId: 717982248
---
 internal/platform/blocking_queue_stream.cc | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/internal/platform/blocking_queue_stream.cc b/internal/platform/blocking_queue_stream.cc
index ffe33751..caa5579c 100644
--- a/internal/platform/blocking_queue_stream.cc
+++ b/internal/platform/blocking_queue_stream.cc
@@ -41,13 +41,13 @@ ExceptionOr<ByteArray> BlockingQueueStream::Read(std::int64_t size) {
   if (is_closed_) {
     LOG(INFO)
         << "Failed to read BlockingQueueStream because it was closed.";
-    return ExceptionOr<ByteArray>(Exception::kInterrupted);
+    return ExceptionOr<ByteArray>(Exception::kIo);
   }
 
   ByteArray bytes = queue_head_.Empty() ? blocking_queue_.Take() : queue_head_;
   if (bytes == queue_end_) {
     LOG(INFO) << "BlockingQueueStream is Interrupted.";
-    return ExceptionOr<ByteArray>(Exception::kInterrupted);
+    return ExceptionOr<ByteArray>(Exception::kIo);
   }
 
   int copy_len = std::min<int>(size, bytes.size());