| 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)
|
|
|