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

Side by Side Diff: Source/core/streams/ReadableStream.h

Issue 712043002: Make ReadableStream implementation up to date. (Closed) Base URL: https://chromium.googlesource.com/chromium/blink.git@master
Patch Set: Created 6 years, 1 month 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
« no previous file with comments | « no previous file | Source/core/streams/ReadableStream.cpp » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 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
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
OLDNEW
« no previous file with comments | « no previous file | Source/core/streams/ReadableStream.cpp » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698