| /third_party/node/lib/internal/webstreams/ |
| D | writablestream.js | 67 kState,
160 this[kState] = {
270 state: this[kState].state,
278 this[kState].transfer.port1?.close();
279 this[kState].transfer.port1 = undefined;
280 this[kState].transfer.port2 = undefined;
291 this[kState].transfer.port1);
293 this[kState].transfer.readable = readable;
294 this[kState].transfer.promise = promise;
296 setPromiseHandled(this[kState].transfer.promise);
[all …]
|
| D | readablestream.js | 115 kState,
249 this[kState] = {
298 return this[kState].disturbed;
302 return this[kState].state === 'errored';
306 return this[kState].state === 'readable';
487 if (reader[kState].stream === undefined) {
520 if (reader[kState].stream === undefined) {
524 assert(!reader[kState].readRequests.length);
580 state: this[kState].state,
583 this[kState].controller instanceof ReadableByteStreamController,
[all …]
|
| D | transformstream.js | 48 kState,
169 this[kState].controller));
185 return this[kState].readable;
195 return this[kState].writable;
202 backpressure: this[kState].backpressure,
212 } = this[kState];
234 return [ this[kState].readable, this[kState].writable ];
238 this[kState].readable = readable;
239 this[kState].writable = writable;
253 this[kState] = {
[all …]
|
| 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 …]
|
| D | util.js | 54 const kState = Symbol('kState'); constant
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].queue !== undefined);
164 assert(controller[kState].queueTotalSize !== undefined);
[all …]
|
| 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/ |
| 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].findIndex((entry) => entry.name === name)
146 this[kState] = [
[all …]
|
| D | response.js | 21 const { kState, kHeaders, kGuard, kRealm } = require('./symbols')
43 responseObject[kState] = makeNetworkError()
45 responseObject[kHeaders][kHeadersList] = responseObject[kState].headersList
117 responseObject[kState].status = status
123 responseObject[kState].headersList.append('location', value)
141 this[kState] = makeResponse({})
148 this[kHeaders][kHeadersList] = this[kState].headersList
169 return this[kState].type
176 const urlList = this[kState].urlList
196 return this[kState].urlList.length > 1
[all …]
|
| D | file.js | 5 const { kState } = require('./symbols')
69 this[kState] = {
79 return this[kState].name
85 return this[kState].lastModified
91 return this[kState].type
135 this[kState] = {
146 return this[kState].blobLike.stream(...args)
152 return this[kState].blobLike.arrayBuffer(...args)
158 return this[kState].blobLike.slice(...args)
164 return this[kState].blobLike.text(...args)
[all …]
|
| D | request.js | 26 const { kHeaders, kSignal, kState, kGuard, kRealm } = require('./symbols')
110 request = input[kState]
335 this[kState] = request
439 const inputBody = input instanceof Request ? input[kState].body : null
526 this[kState].body = finalBody
534 return this[kState].method
542 return URLSerializer(this[kState].url)
561 return this[kState].destination
574 if (this[kState].referrer === 'no-referrer') {
580 if (this[kState].referrer === 'client') {
[all …]
|
| D | body.js | 14 const { kState } = require('./symbols')
374 throwIfAborted(this[kState])
433 …if (this.body !== null) for await (const chunk of consumeBody(this[kState].body)) busboy.write(chu…
448 for await (const chunk of consumeBody(this[kState].body)) {
473 throwIfAborted(this[kState])
500 throwIfAborted(object[kState])
504 if (bodyUnusable(object[kState].body)) {
528 if (object[kState].body == null) {
535 fullyReadBody(object[kState].body, successSteps, errorSteps)
588 const { headersList } = object[kState]
|
| /third_party/node/lib/internal/http2/ |
| D | compat.js | 72 const kState = Symbol('state'); constant
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 …]
|
| D | core.js | 249 const kState = Symbol('state'); constant
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].streams.get(id) || session;
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-whatwg-webstreams-adapters-to-streamduplex.js | 24 kState,
37 assert.strictEqual(transform.readable[kState].state, 'closed');
38 assert.strictEqual(transform.writable[kState].state, 'errored');
56 assert.strictEqual(transform.readable[kState].state, 'closed');
57 assert.strictEqual(transform.writable[kState].state, 'errored');
58 assert.strictEqual(transform.writable[kState].storedError, error);
70 assert.strictEqual(transform.readable[kState].state, 'closed');
71 assert.strictEqual(transform.writable[kState].state, 'closed');
95 assert.strictEqual(transform.readable[kState].state, 'closed');
96 assert.strictEqual(transform.writable[kState].state, 'closed');
|
| D | test-whatwg-readablebytestream.js | 16 kState,
40 assert(r[kState].controller instanceof ReadableByteStreamController);
122 assert(stream[kState].controller instanceof ReadableByteStreamController);
146 assert(stream[kState].controller instanceof ReadableByteStreamController);
164 assert(stream[kState].controller instanceof ReadableByteStreamController);
177 assert(stream[kState].controller instanceof ReadableByteStreamController);
|
| D | test-whatwg-webstreams-adapters-to-streamwritable.js | 23 kState,
67 assert.strictEqual(writableStream[kState].state, 'closed');
86 assert.strictEqual(writableStream[kState].state, 'closed');
109 assert.strictEqual(writableStream[kState].state, 'errored');
110 assert.strictEqual(writableStream[kState].storedError, error);
|
| D | test-whatwg-webstreams-adapters-to-readablestream.js | 18 kState,
69 assert.strictEqual(readableStream[kState].state, 'errored');
97 assert.strictEqual(readableStream[kState].state, 'closed');
127 assert.strictEqual(readableStream[kState].state, 'errored');
|
| /third_party/node/deps/undici/src/lib/cache/ |
| 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/deps/undici/src/lib/fileapi/ |
| D | progressevent.js | 5 const kState = Symbol('ProgressEvent state') constant
17 this[kState] = {
27 return this[kState].lengthComputable
33 return this[kState].loaded
39 return this[kState].total
|
| 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') {
|
| D | filereader.js | 9 kState,
22 this[kState] = 'empty'
111 if (this[kState] === 'empty' || this[kState] === 'done') {
118 if (this[kState] === 'loading') {
119 this[kState] = 'done'
136 if (this[kState] !== 'loading') {
147 switch (this[kState]) {
|
| /third_party/node/lib/internal/crypto/ |
| D | hash.js | 57 const kState = Symbol('kState'); constant
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/skia/third_party/externals/abseil-cpp/absl/random/internal/ |
| D | pool_urbg.cc | 52 static constexpr size_t kState = RandenTraits::kStateBytes / sizeof(uint32_t); member in absl::random_internal::__anon0c3cfc510111::RandenPoolEntry
59 next_ = kState; in Init()
70 if (next_ >= kState) { in MaybeRefill()
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/ |
| D | blob.js | 69 const kState = Symbol('kState'); constant
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/deps/undici/ |
| D | undici.js | 82 kState: Symbol("state"), property
3864 var { kState } = require_symbols2();
3890 this[kState] = {
3898 return this[kState].name;
3902 return this[kState].lastModified;
3906 return this[kState].type;
3914 this[kState] = {
3923 return this[kState].blobLike.stream(...args);
3927 return this[kState].blobLike.arrayBuffer(...args);
3931 return this[kState].blobLike.slice(...args);
[all …]
|