Lines Matching refs:kState

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] = {
191           if (this[kState].backpressurePromise !== undefined)
192             this[kState].backpressurePromise.resolve?.();
193           this[kState].backpressurePromise = undefined;
197             this[kState].controller,
199           if (this[kState].backpressurePromise !== undefined)
200             this[kState].backpressurePromise.resolve?.();
201           this[kState].backpressurePromise = undefined;
211         this[kState].controller,
219     this[kState].controller = controller;
223     if (this[kState].backpressurePromise === undefined) {
224       this[kState].backpressurePromise = {
230     await this[kState].backpressurePromise.promise;
231     this[kState].backpressurePromise = createDeferredPromise();
233       this[kState].port.postMessage({ type: 'chunk', value: chunk });
239       this[kState].port.postMessage({ type: 'error', value: error });
240       this[kState].port.close();
246     this[kState].port.postMessage({ type: 'close' });
247     this[kState].port.close();
252       this[kState].port.postMessage({ type: 'error', value: reason });
258       this[kState].port.postMessage({ type: 'error', value: error });
261       this[kState].port.close();