Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(36)

Side by Side Diff: third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.h

Issue 1908213004: [Streams] Remove SetReadableStreamDisturbed from ReadableStream.js (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef BodyStreamBuffer_h 5 #ifndef BodyStreamBuffer_h
6 #define BodyStreamBuffer_h 6 #define BodyStreamBuffer_h
7 7
8 #include "bindings/core/v8/ScriptPromise.h" 8 #include "bindings/core/v8/ScriptPromise.h"
9 #include "bindings/core/v8/ScriptValue.h" 9 #include "bindings/core/v8/ScriptValue.h"
10 #include "core/dom/DOMException.h" 10 #include "core/dom/DOMException.h"
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after
59 void stop() override; 59 void stop() override;
60 60
61 // WebDataConsumerHandle::Client 61 // WebDataConsumerHandle::Client
62 void didGetReadable() override; 62 void didGetReadable() override;
63 63
64 bool isStreamReadable(); 64 bool isStreamReadable();
65 bool isStreamClosed(); 65 bool isStreamClosed();
66 bool isStreamErrored(); 66 bool isStreamErrored();
67 bool isStreamLocked(); 67 bool isStreamLocked();
68 bool isStreamDisturbed(); 68 bool isStreamDisturbed();
69 void setDisturbed(); 69 void closeAndLockAndDisturb();
70 70
71 DEFINE_INLINE_TRACE() 71 DEFINE_INLINE_TRACE()
72 { 72 {
73 visitor->trace(m_stream); 73 visitor->trace(m_stream);
74 visitor->trace(m_loader); 74 visitor->trace(m_loader);
75 UnderlyingSourceBase::trace(visitor); 75 UnderlyingSourceBase::trace(visitor);
76 UnderlyingSource::trace(visitor); 76 UnderlyingSource::trace(visitor);
77 } 77 }
78 78
79 private: 79 private:
80 class LoaderClient; 80 class LoaderClient;
81 81
82 void lockAndDisturb();
83 void close(); 82 void close();
84 void error(); 83 void error();
85 void processData(); 84 void processData();
86 void endLoading(); 85 void endLoading();
87 void stopLoading(); 86 void stopLoading();
88 87
89 RefPtr<ScriptState> m_scriptState; 88 RefPtr<ScriptState> m_scriptState;
90 OwnPtr<FetchDataConsumerHandle> m_handle; 89 OwnPtr<FetchDataConsumerHandle> m_handle;
91 OwnPtr<FetchDataConsumerHandle::Reader> m_reader; 90 OwnPtr<FetchDataConsumerHandle::Reader> m_reader;
92 Member<ReadableByteStream> m_stream; 91 Member<ReadableByteStream> m_stream;
93 // We need this member to keep it alive while loading. 92 // We need this member to keep it alive while loading.
94 Member<FetchDataLoader> m_loader; 93 Member<FetchDataLoader> m_loader;
95 bool m_streamNeedsMore = false; 94 bool m_streamNeedsMore = false;
96 }; 95 };
97 96
98 } // namespace blink 97 } // namespace blink
99 98
100 #endif // BodyStreamBuffer_h 99 #endif // BodyStreamBuffer_h
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698