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

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

Issue 2177243002: Use per-frame TaskRunner instead of thread's default in DataConsumerHandle (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@data_consumer_handle_unique_ptr
Patch Set: update Created 4 years, 4 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 39 matching lines...) Expand 10 before | Expand all | Expand 10 after
50 ScriptPromise cancelSource(ScriptState*, ScriptValue reason) override; 50 ScriptPromise cancelSource(ScriptState*, ScriptValue reason) override;
51 51
52 // UnderlyingSourceBase 52 // UnderlyingSourceBase
53 ScriptPromise pull(ScriptState*) override; 53 ScriptPromise pull(ScriptState*) override;
54 ScriptPromise cancel(ScriptState*, ScriptValue reason) override; 54 ScriptPromise cancel(ScriptState*, ScriptValue reason) override;
55 bool hasPendingActivity() const override; 55 bool hasPendingActivity() const override;
56 void stop() override; 56 void stop() override;
57 57
58 // WebDataConsumerHandle::Client 58 // WebDataConsumerHandle::Client
59 void didGetReadable() override; 59 void didGetReadable() override;
60 WebTaskRunner* getTaskRunner() override;
60 61
61 bool isStreamReadable(); 62 bool isStreamReadable();
62 bool isStreamClosed(); 63 bool isStreamClosed();
63 bool isStreamErrored(); 64 bool isStreamErrored();
64 bool isStreamLocked(); 65 bool isStreamLocked();
65 bool isStreamDisturbed(); 66 bool isStreamDisturbed();
66 void closeAndLockAndDisturb(); 67 void closeAndLockAndDisturb();
67 ScriptState* scriptState() { return m_scriptState.get(); } 68 ScriptState* scriptState() { return m_scriptState.get(); }
68 69
69 DEFINE_INLINE_TRACE() 70 DEFINE_INLINE_TRACE()
(...skipping 20 matching lines...) Expand all
90 Member<ReadableByteStream> m_stream; 91 Member<ReadableByteStream> m_stream;
91 // We need this member to keep it alive while loading. 92 // We need this member to keep it alive while loading.
92 Member<FetchDataLoader> m_loader; 93 Member<FetchDataLoader> m_loader;
93 bool m_streamNeedsMore = false; 94 bool m_streamNeedsMore = false;
94 bool m_madeFromReadableStream; 95 bool m_madeFromReadableStream;
95 }; 96 };
96 97
97 } // namespace blink 98 } // namespace blink
98 99
99 #endif // BodyStreamBuffer_h 100 #endif // BodyStreamBuffer_h
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698