| OLD | NEW |
| 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 Loading... |
| 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 Loading... |
| 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 }); |
| OLD | NEW |