| OLD | NEW |
| 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 "core/dom/DOMException.h" | 8 #include "core/dom/DOMException.h" |
| 9 #include "core/streams/ReadableByteStream.h" | 9 #include "core/streams/ReadableByteStream.h" |
| 10 #include "core/streams/ReadableByteStreamReader.h" | 10 #include "core/streams/ReadableByteStreamReader.h" |
| (...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 48 bool hasPendingActivity() const; | 48 bool hasPendingActivity() const; |
| 49 void stop(); | 49 void stop(); |
| 50 | 50 |
| 51 // UnderlyingSource | 51 // UnderlyingSource |
| 52 void pullSource() override; | 52 void pullSource() override; |
| 53 ScriptPromise cancelSource(ScriptState*, ScriptValue reason) override; | 53 ScriptPromise cancelSource(ScriptState*, ScriptValue reason) override; |
| 54 | 54 |
| 55 // WebDataConsumerHandle::Client | 55 // WebDataConsumerHandle::Client |
| 56 void didGetReadable() override; | 56 void didGetReadable() override; |
| 57 | 57 |
| 58 bool isStreamReadable() const; |
| 59 bool isStreamClosed() const; |
| 60 bool isStreamErrored() const; |
| 61 bool isStreamLocked() const; |
| 62 bool isStreamDisturbed() const; |
| 63 |
| 58 DEFINE_INLINE_TRACE() | 64 DEFINE_INLINE_TRACE() |
| 59 { | 65 { |
| 60 visitor->trace(m_stream); | 66 visitor->trace(m_stream); |
| 61 visitor->trace(m_loader); | 67 visitor->trace(m_loader); |
| 62 UnderlyingSource::trace(visitor); | 68 UnderlyingSource::trace(visitor); |
| 63 } | 69 } |
| 64 | 70 |
| 65 private: | 71 private: |
| 66 class LoaderClient; | 72 class LoaderClient; |
| 67 void close(); | 73 void close(); |
| 68 void error(); | 74 void error(); |
| 69 void processData(); | 75 void processData(); |
| 70 void endLoading(); | 76 void endLoading(); |
| 71 void stopLoading(); | 77 void stopLoading(); |
| 72 | 78 |
| 73 OwnPtr<FetchDataConsumerHandle> m_handle; | 79 OwnPtr<FetchDataConsumerHandle> m_handle; |
| 74 OwnPtr<FetchDataConsumerHandle::Reader> m_reader; | 80 OwnPtr<FetchDataConsumerHandle::Reader> m_reader; |
| 75 Member<ReadableByteStream> m_stream; | 81 Member<ReadableByteStream> m_stream; |
| 76 // We need this member to keep it alive while loading. | 82 // We need this member to keep it alive while loading. |
| 77 Member<FetchDataLoader> m_loader; | 83 Member<FetchDataLoader> m_loader; |
| 78 bool m_streamNeedsMore; | 84 bool m_streamNeedsMore; |
| 79 }; | 85 }; |
| 80 | 86 |
| 81 } // namespace blink | 87 } // namespace blink |
| 82 | 88 |
| 83 #endif // BodyStreamBuffer_h | 89 #endif // BodyStreamBuffer_h |
| OLD | NEW |