Index: Source/core/streams/ReadableStream.cpp |
diff --git a/Source/core/streams/ReadableStream.cpp b/Source/core/streams/ReadableStream.cpp |
index b4e92a5737e9ae92b7e942f0471147f86950b799..b67e0232b193c21927f4af4e4d5f6f3d144d73b1 100644 |
--- a/Source/core/streams/ReadableStream.cpp |
+++ b/Source/core/streams/ReadableStream.cpp |
@@ -71,8 +71,7 @@ bool ReadableStream::enqueuePostAction(size_t totalQueueSize) |
if (m_state == Waiting) { |
m_state = Readable; |
- if (m_wait->state() == m_wait->Pending) |
- m_wait->resolve(V8UndefinedType()); |
+ m_wait->resolve(V8UndefinedType()); |
} |
return needsMore; |
@@ -81,8 +80,7 @@ bool ReadableStream::enqueuePostAction(size_t totalQueueSize) |
void ReadableStream::close() |
{ |
if (m_state == Waiting) { |
- if (m_wait->state() == m_wait->Pending) |
- m_wait->resolve(V8UndefinedType()); |
+ m_wait->resolve(V8UndefinedType()); |
m_closed->resolve(V8UndefinedType()); |
m_state = Closed; |
} else if (m_state == Readable) { |
@@ -112,15 +110,12 @@ void ReadableStream::readPostAction() |
if (isQueueEmpty()) { |
if (m_isDraining) { |
m_state = Closed; |
- // FIXME: Use reset. |
- // m_wait->reset(); |
- if (m_wait->state() == m_wait->Pending) |
- m_wait->resolve(V8UndefinedType()); |
+ m_wait->reset(); |
+ m_wait->resolve(V8UndefinedType()); |
m_closed->resolve(V8UndefinedType()); |
} else { |
m_state = Waiting; |
- // FIXME: Use reset. |
- // m_wait->reset(); |
+ m_wait->reset(); |
callOrSchedulePull(); |
} |
} |
@@ -145,14 +140,11 @@ ScriptPromise ReadableStream::cancel(ScriptState* scriptState, ScriptValue reaso |
return ScriptPromise::cast(scriptState, v8::Undefined(scriptState->isolate())); |
if (m_state == Waiting) { |
- if (m_wait->state() == m_wait->Pending) |
- m_wait->resolve(V8UndefinedType()); |
+ m_wait->resolve(V8UndefinedType()); |
} else { |
ASSERT(m_state == Readable); |
- // FIXME: Use reset here. |
- // m_wait->reset(); |
- if (m_wait->state() == m_wait->Pending) |
- m_wait->resolve(V8UndefinedType()); |
+ m_wait->reset(); |
+ m_wait->resolve(V8UndefinedType()); |
} |
clearQueue(); |
@@ -170,8 +162,7 @@ void ReadableStream::error(PassRefPtrWillBeRawPtr<DOMException> exception) |
{ |
if (m_state == Readable) { |
clearQueue(); |
- // FIXME: Use reset here. |
- // m_wait->reset(); |
+ m_wait->reset(); |
} |
if (m_state == Waiting || m_state == Readable) { |