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

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

Issue 1898873003: Add ReadableStream operations to use it from Fetch API (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@body-stream-buffer-test-refactoring
Patch Set: Created 4 years, 8 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 469 matching lines...) Expand 10 before | Expand all | Expand 10 after
480 } 480 }
481 481
482 function IsReadableStream(x) { 482 function IsReadableStream(x) {
483 return hasOwnProperty(x, readableStreamUnderlyingSource); 483 return hasOwnProperty(x, readableStreamUnderlyingSource);
484 } 484 }
485 485
486 function IsReadableStreamDisturbed(stream) { 486 function IsReadableStreamDisturbed(stream) {
487 return stream[readableStreamBits] & DISTURBED; 487 return stream[readableStreamBits] & DISTURBED;
488 } 488 }
489 489
490 function SetReadableStreamDisturbed(stream) {
491 return stream[readableStreamBits] |= DISTURBED;
492 }
493
490 function IsReadableStreamLocked(stream) { 494 function IsReadableStreamLocked(stream) {
491 return stream[readableStreamReader] !== undefined; 495 return stream[readableStreamReader] !== undefined;
492 } 496 }
493 497
494 function IsReadableStreamController(x) { 498 function IsReadableStreamController(x) {
495 return hasOwnProperty(x, readableStreamControllerControlledReadableStream); 499 return hasOwnProperty(x, readableStreamControllerControlledReadableStream);
496 } 500 }
497 501
502 function IsReadableStreamReadable(stream) {
503 return stream[readableStreamState] === STATE_READABLE;
504 }
505
506 function IsReadableStreamClosed(stream) {
507 return stream[readableStreamState] === STATE_CLOSED;
508 }
509
510 function IsReadableStreamErrored(stream) {
511 return stream[readableStreamState] === STATE_ERRORED;
512 }
513
498 function IsReadableStreamReader(x) { 514 function IsReadableStreamReader(x) {
499 return hasOwnProperty(x, readableStreamReaderOwnerReadableStream); 515 return hasOwnProperty(x, readableStreamReaderOwnerReadableStream);
500 } 516 }
501 517
502 function ReadFromReadableStreamReader(reader) { 518 function ReadFromReadableStreamReader(reader) {
503 const stream = reader[readableStreamReaderOwnerReadableStream]; 519 const stream = reader[readableStreamReaderOwnerReadableStream];
504 stream[readableStreamBits] |= DISTURBED; 520 stream[readableStreamBits] |= DISTURBED;
505 521
506 if (stream[readableStreamState] === STATE_CLOSED) { 522 if (stream[readableStreamState] === STATE_CLOSED) {
507 return Promise_resolve(CreateIterResultObject(undefined, true)); 523 return Promise_resolve(CreateIterResultObject(undefined, true));
(...skipping 269 matching lines...) Expand 10 before | Expand all | Expand 10 after
777 writable: true 793 writable: true
778 }); 794 });
779 795
780 // 796 //
781 // Exports to Blink 797 // Exports to Blink
782 // 798 //
783 799
784 binding.AcquireReadableStreamReader = AcquireReadableStreamReader; 800 binding.AcquireReadableStreamReader = AcquireReadableStreamReader;
785 binding.IsReadableStream = IsReadableStream; 801 binding.IsReadableStream = IsReadableStream;
786 binding.IsReadableStreamDisturbed = IsReadableStreamDisturbed; 802 binding.IsReadableStreamDisturbed = IsReadableStreamDisturbed;
803 binding.SetReadableStreamDisturbed = SetReadableStreamDisturbed;
787 binding.IsReadableStreamLocked = IsReadableStreamLocked; 804 binding.IsReadableStreamLocked = IsReadableStreamLocked;
805 binding.IsReadableStreamReadable = IsReadableStreamReadable;
806 binding.IsReadableStreamClosed = IsReadableStreamClosed;
807 binding.IsReadableStreamErrored = IsReadableStreamErrored;
788 binding.IsReadableStreamReader = IsReadableStreamReader; 808 binding.IsReadableStreamReader = IsReadableStreamReader;
789 binding.ReadFromReadableStreamReader = ReadFromReadableStreamReader; 809 binding.ReadFromReadableStreamReader = ReadFromReadableStreamReader;
790 810
791 binding.CloseReadableStream = CloseReadableStream; 811 binding.CloseReadableStream = CloseReadableStream;
792 binding.GetReadableStreamDesiredSize = GetReadableStreamDesiredSize; 812 binding.GetReadableStreamDesiredSize = GetReadableStreamDesiredSize;
793 binding.EnqueueInReadableStream = EnqueueInReadableStream; 813 binding.EnqueueInReadableStream = EnqueueInReadableStream;
794 binding.ErrorReadableStream = ErrorReadableStream; 814 binding.ErrorReadableStream = ErrorReadableStream;
795 815
796 binding.createReadableStreamWithExternalController = 816 binding.createReadableStreamWithExternalController =
797 (underlyingSource, strategy) => { 817 (underlyingSource, strategy) => {
798 return new ReadableStream( 818 return new ReadableStream(
799 underlyingSource, strategy, createWithExternalControllerSentinel); 819 underlyingSource, strategy, createWithExternalControllerSentinel);
800 }; 820 };
801 }); 821 });
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