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 ReadableStream_h | 5 #ifndef ReadableStream_h |
6 #define ReadableStream_h | 6 #define ReadableStream_h |
7 | 7 |
8 #include "bindings/core/v8/ScriptPromise.h" | 8 #include "bindings/core/v8/ScriptPromise.h" |
9 #include "bindings/core/v8/ScriptPromiseProperty.h" | 9 #include "bindings/core/v8/ScriptPromiseProperty.h" |
10 #include "bindings/core/v8/ScriptState.h" | 10 #include "bindings/core/v8/ScriptState.h" |
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
65 void readPreliminaryCheck(ExceptionState&); | 65 void readPreliminaryCheck(ExceptionState&); |
66 void readPostAction(); | 66 void readPostAction(); |
67 | 67 |
68 private: | 68 private: |
69 typedef ScriptPromiseProperty<Member<ReadableStream>, V8UndefinedType, RefPt
rWillBeMember<DOMException> > WaitPromise; | 69 typedef ScriptPromiseProperty<Member<ReadableStream>, V8UndefinedType, RefPt
rWillBeMember<DOMException> > WaitPromise; |
70 typedef ScriptPromiseProperty<Member<ReadableStream>, V8UndefinedType, RefPt
rWillBeMember<DOMException> > ClosedPromise; | 70 typedef ScriptPromiseProperty<Member<ReadableStream>, V8UndefinedType, RefPt
rWillBeMember<DOMException> > ClosedPromise; |
71 | 71 |
72 virtual bool isQueueEmpty() const = 0; | 72 virtual bool isQueueEmpty() const = 0; |
73 virtual void clearQueue() = 0; | 73 virtual void clearQueue() = 0; |
74 | 74 |
75 void callOrSchedulePull(); | 75 void callPullIfNeeded(); |
76 | 76 |
77 Member<UnderlyingSource> m_source; | 77 Member<UnderlyingSource> m_source; |
78 bool m_isStarted; | 78 bool m_isStarted; |
79 bool m_isDraining; | 79 bool m_isDraining; |
80 bool m_isPulling; | 80 bool m_isPulling; |
81 bool m_isSchedulingPull; | |
82 State m_state; | 81 State m_state; |
83 | 82 |
84 Member<WaitPromise> m_wait; | 83 Member<WaitPromise> m_wait; |
85 Member<ClosedPromise> m_closed; | 84 Member<ClosedPromise> m_closed; |
86 RefPtrWillBeMember<DOMException> m_exception; | 85 RefPtrWillBeMember<DOMException> m_exception; |
87 }; | 86 }; |
88 | 87 |
89 } // namespace blink | 88 } // namespace blink |
90 | 89 |
91 #endif // ReadableStream_h | 90 #endif // ReadableStream_h |
OLD | NEW |