Index: Source/modules/fetch/Body.cpp |
diff --git a/Source/modules/fetch/Body.cpp b/Source/modules/fetch/Body.cpp |
index b90a6ca9c0452344f034f2e65f0a02c6656e8c4c..3d2b1cdfb4a0722f35a48d56d4693ca4a4035e87 100644 |
--- a/Source/modules/fetch/Body.cpp |
+++ b/Source/modules/fetch/Body.cpp |
@@ -113,8 +113,8 @@ |
} |
// Take back the data in |m_stream|. |
Deque<std::pair<RefPtr<DOMArrayBuffer>, size_t>> tmp_queue; |
- if (m_stream->stateInternal() == ReadableStream::Readable) |
- m_stream->readInternal(tmp_queue); |
+ if (m_stream->state() == ReadableStream::Readable) |
+ m_stream->read(tmp_queue); |
*dataLost = m_queueCount != tmp_queue.size(); |
while (!tmp_queue.isEmpty()) { |
std::pair<RefPtr<DOMArrayBuffer>, size_t> data = tmp_queue.takeFirst(); |
@@ -379,7 +379,7 @@ |
{ |
if (m_resolver) |
return true; |
- if (m_stream && m_stream->hasPendingActivity()) |
+ if (m_stream && (m_stream->state() == ReadableStream::Readable || m_stream->state() == ReadableStream::Waiting)) |
return true; |
return false; |
} |