增加井号重复判断

‘liusuyi’

2023-07-03 29d8ea701df5bba27bda837a550853b299207040

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
'use strict';
 
var GetIntrinsic = require('get-intrinsic');
 
var $TypeError = GetIntrinsic('%TypeError%');
 
var AsyncFromSyncIteratorContinuation = require('./AsyncFromSyncIteratorContinuation');
var Call = require('./Call');
var CreateIterResultObject = require('./CreateIterResultObject');
var Get = require('./Get');
var GetMethod = require('./GetMethod');
var IteratorNext = require('./IteratorNext');
var ObjectCreate = require('./ObjectCreate');
var Type = require('./Type');
 
var SLOT = require('internal-slot');
 
var assertRecord = require('../helpers/assertRecord');
 
var $AsyncFromSyncIteratorPrototype = GetIntrinsic('%AsyncFromSyncIteratorPrototype%', true) || {
    next: function next(value) {
        var O = this; // step 1
 
        SLOT.assert(O, '[[SyncIteratorRecord]]'); // step 2
 
        var argsLength = arguments.length;
 
        return new Promise(function (resolve) { // step 3
            var syncIteratorRecord = SLOT.get(O, '[[SyncIteratorRecord]]'); // step 4
            var result;
            if (argsLength > 0) {
                result = IteratorNext(syncIteratorRecord['[[Iterator]]'], value); // step 5.a
            } else { // step 6
                result = IteratorNext(syncIteratorRecord['[[Iterator]]']);// step 6.a
            }
            resolve(AsyncFromSyncIteratorContinuation(result)); // step 8
        });
    },
    'return': function () {
        var O = this; // step 1
 
        SLOT.assert(O, '[[SyncIteratorRecord]]'); // step 2
 
        var valueIsPresent = arguments.length > 0;
        var value = valueIsPresent ? arguments[0] : void undefined;
 
        return new Promise(function (resolve, reject) { // step 3
            var syncIterator = SLOT.get(O, '[[SyncIteratorRecord]]')['[[Iterator]]']; // step 4
            var iteratorReturn = GetMethod(syncIterator, 'return'); // step 5
 
            if (typeof iteratorReturn === 'undefined') { // step 7
                var iterResult = CreateIterResultObject(value, true); // step 7.a
                Call(resolve, undefined, [iterResult]); // step 7.b
                return;
            }
            var result;
            if (valueIsPresent) { // step 8
                result = Call(iteratorReturn, syncIterator, [value]); // step 8.a
            } else { // step 9
                result = Call(iteratorReturn, syncIterator); // step 9.a
            }
            if (Type(result) !== 'Object') { // step 11
                Call(reject, undefined, [new $TypeError('Iterator `return` method returned a non-object value.')]); // step 11.a
                return;
            }
 
            resolve(AsyncFromSyncIteratorContinuation(result)); // step 12
        });
    },
    'throw': function () {
        var O = this; // step 1
 
        SLOT.assert(O, '[[SyncIteratorRecord]]'); // step 2
 
        var valueIsPresent = arguments.length > 0;
        var value = valueIsPresent ? arguments[0] : void undefined;
 
        return new Promise(function (resolve, reject) { // step 3
            var syncIterator = SLOT.get(O, '[[SyncIteratorRecord]]')['[[Iterator]]']; // step 4
 
            var throwMethod = GetMethod(syncIterator, 'throw'); // step 5
 
            if (typeof throwMethod === 'undefined') { // step 7
                Call(reject, undefined, [value]); // step 7.a
                return;
            }
 
            var result;
            if (valueIsPresent) { // step 8
                result = Call(throwMethod, syncIterator, [value]); // step 8.a
            } else { // step 9
                result = Call(throwMethod, syncIterator); // step 9.a
            }
            if (Type(result) !== 'Object') { // step 11
                Call(reject, undefined, [new $TypeError('Iterator `throw` method returned a non-object value.')]); // step 11.a
                return;
            }
 
            resolve(AsyncFromSyncIteratorContinuation(result/* , promiseCapability */)); // step 12
        });
    }
};
 
// https://ecma-international.org/ecma-262/10.0/#sec-createasyncfromsynciterator
 
module.exports = function CreateAsyncFromSyncIterator(syncIteratorRecord) {
    assertRecord(Type, 'Iterator Record', 'syncIteratorRecord', syncIteratorRecord);
 
    // var asyncIterator = ObjectCreate(%AsyncFromSyncIteratorPrototype%, « [[SyncIteratorRecord]] »); // step 1
    var asyncIterator = ObjectCreate($AsyncFromSyncIteratorPrototype);
 
    SLOT.set(asyncIterator, '[[SyncIteratorRecord]]', syncIteratorRecord); // step 2
 
    var nextMethod = Get(asyncIterator, 'next'); // step 3
 
    return { // steps 3-4
        '[[Iterator]]': asyncIterator,
        '[[NextMethod]]': nextMethod,
        '[[Done]]': false
    };
};