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

Side by Side Diff: third_party/WebKit/Source/core/streams/ReadableStream.js

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
« no previous file with comments | « no previous file | third_party/WebKit/Source/core/streams/ReadableStreamOperations.h » ('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 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 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 (function(global, binding, v8) { 5 (function(global, binding, v8) {
6 'use strict'; 6 'use strict';
7 7
8 const readableStreamController = v8.createPrivateSymbol('[[controller]]'); 8 const readableStreamController = v8.createPrivateSymbol('[[controller]]');
9 const readableStreamQueue = v8.createPrivateSymbol('[[queue]]'); 9 const readableStreamQueue = v8.createPrivateSymbol('[[queue]]');
10 const readableStreamQueueSize = 10 const readableStreamQueueSize =
(...skipping 487 matching lines...) Expand 10 before | Expand all | Expand 10 after
498 } 498 }
499 499
500 function IsReadableStream(x) { 500 function IsReadableStream(x) {
501 return hasOwnProperty(x, readableStreamUnderlyingSource); 501 return hasOwnProperty(x, readableStreamUnderlyingSource);
502 } 502 }
503 503
504 function IsReadableStreamDisturbed(stream) { 504 function IsReadableStreamDisturbed(stream) {
505 return stream[readableStreamBits] & DISTURBED; 505 return stream[readableStreamBits] & DISTURBED;
506 } 506 }
507 507
508 function SetReadableStreamDisturbed(stream) {
509 return stream[readableStreamBits] |= DISTURBED;
510 }
511
512 function IsReadableStreamLocked(stream) { 508 function IsReadableStreamLocked(stream) {
513 return stream[readableStreamReader] !== undefined; 509 return stream[readableStreamReader] !== undefined;
514 } 510 }
515 511
516 function IsReadableStreamController(x) { 512 function IsReadableStreamController(x) {
517 return hasOwnProperty(x, readableStreamControllerControlledReadableStream); 513 return hasOwnProperty(x, readableStreamControllerControlledReadableStream);
518 } 514 }
519 515
520 function IsReadableStreamReadable(stream) { 516 function IsReadableStreamReadable(stream) {
521 return stream[readableStreamState] === STATE_READABLE; 517 return stream[readableStreamState] === STATE_READABLE;
(...skipping 289 matching lines...) Expand 10 before | Expand all | Expand 10 after
811 writable: true 807 writable: true
812 }); 808 });
813 809
814 // 810 //
815 // Exports to Blink 811 // Exports to Blink
816 // 812 //
817 813
818 binding.AcquireReadableStreamReader = AcquireReadableStreamReader; 814 binding.AcquireReadableStreamReader = AcquireReadableStreamReader;
819 binding.IsReadableStream = IsReadableStream; 815 binding.IsReadableStream = IsReadableStream;
820 binding.IsReadableStreamDisturbed = IsReadableStreamDisturbed; 816 binding.IsReadableStreamDisturbed = IsReadableStreamDisturbed;
821 binding.SetReadableStreamDisturbed = SetReadableStreamDisturbed;
822 binding.IsReadableStreamLocked = IsReadableStreamLocked; 817 binding.IsReadableStreamLocked = IsReadableStreamLocked;
823 binding.IsReadableStreamReadable = IsReadableStreamReadable; 818 binding.IsReadableStreamReadable = IsReadableStreamReadable;
824 binding.IsReadableStreamClosed = IsReadableStreamClosed; 819 binding.IsReadableStreamClosed = IsReadableStreamClosed;
825 binding.IsReadableStreamErrored = IsReadableStreamErrored; 820 binding.IsReadableStreamErrored = IsReadableStreamErrored;
826 binding.IsReadableStreamReader = IsReadableStreamReader; 821 binding.IsReadableStreamReader = IsReadableStreamReader;
827 binding.ReadFromReadableStreamReader = ReadFromReadableStreamReader; 822 binding.ReadFromReadableStreamReader = ReadFromReadableStreamReader;
828 823
829 binding.CloseReadableStream = CloseReadableStream; 824 binding.CloseReadableStream = CloseReadableStream;
830 binding.GetReadableStreamDesiredSize = GetReadableStreamDesiredSize; 825 binding.GetReadableStreamDesiredSize = GetReadableStreamDesiredSize;
831 binding.EnqueueInReadableStream = EnqueueInReadableStream; 826 binding.EnqueueInReadableStream = EnqueueInReadableStream;
832 binding.ErrorReadableStream = ErrorReadableStream; 827 binding.ErrorReadableStream = ErrorReadableStream;
833 828
834 binding.createReadableStreamWithExternalController = 829 binding.createReadableStreamWithExternalController =
835 (underlyingSource, strategy) => { 830 (underlyingSource, strategy) => {
836 return new ReadableStream( 831 return new ReadableStream(
837 underlyingSource, strategy, createWithExternalControllerSentinel); 832 underlyingSource, strategy, createWithExternalControllerSentinel);
838 }; 833 };
839 }); 834 });
OLDNEW
« no previous file with comments | « no previous file | third_party/WebKit/Source/core/streams/ReadableStreamOperations.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698