/third_party/node/lib/internal/webstreams/ |
H A D | transformstream.js | 49 kState, 172 this[kState].controller)); 188 return this[kState].readable; 198 return this[kState].writable; 205 backpressure: this[kState].backpressure, 215 } = this[kState]; 237 return [ this[kState].readable, this[kState].writable ]; 241 this[kState].readable = readable; 242 this[kState] [all...] |
H A D | transfer.js | 10 kState, 108 this[kState] = { 116 } = this[kState]; 144 this[kState].controller, 151 this[kState].controller = controller; 155 this[kState].port.postMessage({ type: 'pull' }); 160 this[kState].port.postMessage({ type: 'error', value: reason }); 166 this[kState].port.postMessage({ type: 'error', value: error }); 169 this[kState].port.close(); 176 this[kState] [all...] |
H A D | util.js | 54 const kState = Symbol('kState'); 128 value[kState] !== undefined && 150 assert(controller[kState].queue !== undefined); 151 assert(controller[kState].queueTotalSize !== undefined); 152 assert(controller[kState].queue.length); 156 } = ArrayPrototypeShift(controller[kState].queue); 157 controller[kState].queueTotalSize = 158 MathMax(0, controller[kState].queueTotalSize - size); 163 assert(controller[kState] [all...] |
H A D | queuingstrategies.js | 25 kState, 85 this[kState] = { 97 return this[kState].highWaterMark; 140 this[kState] = { 152 return this[kState].highWaterMark;
|
/third_party/node/deps/undici/src/lib/fetch/ |
H A D | formdata.js | 4 const { kState } = require('./symbols') 23 this[kState] = [] 52 this[kState].push(entry) 64 this[kState] = this[kState].filter(entry => entry.name !== name) 76 const idx = this[kState].findIndex((entry) => entry.name === name) 83 return this[kState][idx].value 97 return this[kState] 111 return this[kState].findIndex((entry) => entry.name === name) !== -1 144 const idx = this[kState] [all...] |
H A D | response.js | 21 const { kState, kHeaders, kGuard, kRealm } = require('./symbols') 44 responseObject[kState] = makeNetworkError() 46 responseObject[kHeaders][kHeadersList] = responseObject[kState].headersList 118 responseObject[kState].status = status 124 responseObject[kState].headersList.append('location', value) 142 this[kState] = makeResponse({}) 149 this[kHeaders][kHeadersList] = this[kState].headersList 170 return this[kState].type 177 const urlList = this[kState].urlList 197 return this[kState] [all...] |
H A D | file.js | 5 const { kState } = require('./symbols') 70 this[kState] = { 80 return this[kState].name 86 return this[kState].lastModified 92 return this[kState].type 136 this[kState] = { 147 return this[kState].blobLike.stream(...args) 153 return this[kState].blobLike.arrayBuffer(...args) 159 return this[kState].blobLike.slice(...args) 165 return this[kState] [all...] |
H A D | symbols.js | 7 kState: Symbol('state'),
|
H A D | index.js | 45 const { kState, kHeaders, kGuard, kRealm } = require('./symbols') 144 const request = requestObject[kState] 236 responseObject[kState] = response 357 const response = responseObject[kState]
|
/third_party/node/lib/internal/http2/ |
H A D | compat.js | 72 const kState = Symbol('state'); 192 if (request !== undefined && request[kState].closed === false) { 296 const state = req[kState]; 321 this[kState] = { 355 this[kState].closed || 404 const state = this[kState]; 443 if (!this[kState].closed) 459 const state = res[kState]; 478 this[kState] = { 508 const state = this[kState]; [all...] |
H A D | core.js | 249 const kState = Symbol('state'); 346 const streams = session[kState].streams; 374 stream[kState].flags |= STREAM_FLAGS_HEAD_REQUEST; 385 stream[kState].endAfterHeaders = true; 408 const originSet = session[kState].originSet = initOriginSet(session); 430 stream[kState].trailersReady = true; 549 stream[kState].fd = -1; 565 !stream[kState].didRead && 596 const emitter = session[kState].streams.get(id) || session; 611 const emitter = session[kState] [all...] |
/third_party/node/deps/undici/src/lib/cache/ |
H A D | cache.js | 10 const { kState, kHeaders, kGuard, kRealm } = require('../fetch/symbols') 74 r = request[kState] 82 r = new Request(request)[kState] 116 const body = responseObject[kState].body 117 responseObject[kState] = response 118 responseObject[kState].body = body 164 const r = request[kState] 182 const r = new Request(request)[kState] 318 innerRequest = request[kState] 320 innerRequest = new Request(request)[kState] [all...] |
/third_party/node/lib/internal/crypto/ |
H A D | hash.js | 57 const kState = Symbol('kState'); 70 this[kState] = { 80 const state = this[kState]; 100 const state = this[kState]; 118 const state = this[kState]; 137 this[kState] = { 149 const state = this[kState];
|
/third_party/node/deps/undici/src/lib/fileapi/ |
H A D | util.js | 4 kState, 35 if (fr[kState] === 'loading') { 40 fr[kState] = 'loading' 124 fr[kState] = 'done' 154 if (fr[kState] !== 'loading') { 171 fr[kState] = 'done' 181 if (fr[kState] !== 'loading') {
|
H A D | symbols.js | 4 kState: Symbol('FileReader state'),
|
/third_party/skia/third_party/externals/abseil-cpp/absl/random/internal/ |
H A D | pool_urbg.cc | 52 static constexpr size_t kState = RandenTraits::kStateBytes / sizeof(uint32_t); member in absl::random_internal::__anon19294::RandenPoolEntry 59 next_ = kState; in Init() 70 if (next_ >= kState) { in ABSL_EXCLUSIVE_LOCKS_REQUIRED() 78 uint32_t state_[kState] ABSL_GUARDED_BY(mu_); // First to satisfy alignment. 108 if (next_ >= kState - 1) { in Generate() 124 size_t remaining = (kState - next_) * sizeof(state_[0]); in Fill()
|
/third_party/node/lib/internal/ |
H A D | blob.js | 69 const kState = Symbol('kState'); 332 this[kState] = await self.arrayBuffer(); 337 if (this[kState].byteLength - this[kIndex] <= kMaxChunkSize) { 338 controller.enqueue(new Uint8Array(this[kState], this[kIndex])); 340 this[kState] = undefined; 342 controller.enqueue(new Uint8Array(this[kState], this[kIndex], kMaxChunkSize));
|
/third_party/node/test/parallel/ |
H A D | test-whatwg-readablestream.js | 39 kState 93 const controllerState = r1[kState].controller[kState]; 106 const controllerState = r2[kState].controller[kState]; 262 assert.strictEqual(r[kState].state, 'errored'); 263 assert.match(r[kState].storedError?.message, /boom/); 314 assert.strictEqual(reader[kState].stream, stream); 315 assert.strictEqual(stream[kState].reader, reader); 336 assert.strictEqual(reader[kState] [all...] |
H A D | test-whatwg-webstreams-transfer.js | 30 kState, 135 assert(isReadableByteStreamController(readable[kState].controller)); 139 assert(!isReadableByteStreamController(data[kState].controller)); 151 assert(!isReadableByteStreamController(data[kState].controller));
|
/third_party/node/deps/undici/ |
H A D | undici.js | 86 kState: Symbol("state"), 4870 var { kState } = require_symbols2(); 4900 this[kState] = { 4908 return this[kState].name; 4912 return this[kState].lastModified; 4916 return this[kState].type; 4927 this[kState] = { 4936 return this[kState].blobLike.stream(...args); 4940 return this[kState].blobLike.arrayBuffer(...args); 4944 return this[kState] [all...] |