Index: third_party/WebKit/Source/core/streams/ReadableStream.cpp |
diff --git a/third_party/WebKit/Source/core/streams/ReadableStream.cpp b/third_party/WebKit/Source/core/streams/ReadableStream.cpp |
index 77752d3d75a16cb3bdd869bc7343a496920214d8..dd25edbc38f843da0d576acaa44d3318b861a2c1 100644 |
--- a/third_party/WebKit/Source/core/streams/ReadableStream.cpp |
+++ b/third_party/WebKit/Source/core/streams/ReadableStream.cpp |
@@ -111,6 +111,7 @@ ScriptPromise ReadableStream::cancel(ScriptState* scriptState, ScriptValue reaso |
ScriptPromise ReadableStream::cancelInternal(ScriptState* scriptState, ScriptValue reason) |
{ |
+ setIsDisturbed(); |
closeInternal(); |
return m_source->cancelSource(scriptState, reason).then(ConstUndefined::create(scriptState)); |
} |
@@ -125,7 +126,7 @@ void ReadableStream::error(DOMException* exception) |
rejectAllPendingReads(m_exception); |
m_state = Errored; |
if (m_reader) |
- m_reader->releaseLock(); |
+ m_reader->error(); |
} |
void ReadableStream::didSourceStart() |
@@ -179,7 +180,7 @@ void ReadableStream::closeInternal() |
resolveAllPendingReadsAsDone(); |
clearQueue(); |
if (m_reader) |
- m_reader->releaseLock(); |
+ m_reader->close(); |
} |
DEFINE_TRACE(ReadableStream) |