| 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 487 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 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 Loading... |
| 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 }); |
| OLD | NEW |