Home
last modified time | relevance | path

Searched refs:controller (Results 1 - 25 of 82) sorted by relevance

1234

/third_party/node/test/fixtures/wpt/streams/readable-streams/
H A Dfloating-point-total-queue-size.any.js10 const { reader, controller } = setupTestStream();
12 controller.enqueue(2);
13 assert_equals(controller.desiredSize, 0 - 2, 'desiredSize must be -2 after enqueueing such a chunk');
15 controller.enqueue(Number.MAX_SAFE_INTEGER);
16 assert_equals(controller.desiredSize, 0 - Number.MAX_SAFE_INTEGER - 2,
20 assert_equals(controller.desiredSize, 0 - Number.MAX_SAFE_INTEGER - 2 + 2,
25 assert_equals(controller.desiredSize, 0, '[[queueTotalSize]] must clamp to 0 if it becomes negative');
30 const { reader, controller } = setupTestStream();
32 controller.enqueue(1e-16);
33 assert_equals(controller
[all...]
H A Dtemplated.any.js28 let controller;
31 controller = c;
34 controller.close();
40 let controller;
43 controller = c;
47 controller.close();
97 let controller;
100 controller = c;
103 controller.error(theError);
108 let controller;
[all...]
H A Dbad-underlying-sources.any.js143 let controller;
146 controller = c;
151 assert_throws_js(TypeError, () => controller.enqueue('a'), 'Calling enqueue after canceling should throw');
159 let controller;
164 controller = c;
169 assert_throws_js(TypeError, () => controller.enqueue('c'), 'Calling enqueue after canceling should throw');
239 let controller;
243 controller = c;
249 assert_throws_js(TypeError, () => controller.close(), 'Calling close after canceling should throw');
259 let controller;
[all...]
/third_party/node/test/parallel/
H A Dtest-whatwg-events-add-event-listener-options-signal.js19 const controller = new AbortController();
20 et.addEventListener('test', handler, { signal: controller.signal });
25 controller.abort();
27 strictEqual(count, 2, 'Aborting on the controller removes the listener');
31 et.addEventListener('test', handler, { signal: controller.signal }),
44 const controller = new AbortController();
45 et.addEventListener('test', handler, { signal: controller.signal });
58 const controller = new AbortController();
59 const options = { signal: controller.signal, once: true };
61 controller
[all...]
H A Dtest-whatwg-readablestream.js93 const controllerState = r1[kState].controller[kState];
106 const controllerState = r2[kState].controller[kState];
116 start: common.mustCall((controller) => {
117 assert(controller instanceof ReadableStreamDefaultController);
119 pull: common.mustCall((controller) => {
120 assert(controller instanceof ReadableStreamDefaultController);
130 start: common.mustCall(async (controller) => {
131 assert(controller instanceof ReadableStreamDefaultController);
133 pull: common.mustCall(async (controller) => {
134 assert(controller instanceo
[all...]
H A Dtest-whatwg-transformstream.js53 start(controller) {
57 async transform(chunk, controller) {
58 controller.enqueue(chunk.toUpperCase());
95 start(controller) {
98 controller.enqueue(chunk.toString());
102 controller.close();
105 controller.error(error);
170 let controller;
173 controller = c;
181 assert.match(inspect(controller), /TransformStreamDefaultControlle
[all...]
H A Dtest-whatwg-webstreams-transfer.js79 // failing the close R1's controller which signals the end of the data
83 start: common.mustCall((controller) => {
84 controller.enqueue(theData);
85 controller.close();
129 start: common.mustCall((controller) => {
131 controller.enqueue(theByteData.slice());
132 controller.close();
135 assert(isReadableByteStreamController(readable[kState].controller));
139 assert(!isReadableByteStreamController(data[kState].controller));
151 assert(!isReadableByteStreamController(data[kState].controller));
[all...]
H A Dtest-fs-promises-file-handle-writeFile.js38 const controller = new AbortController();
39 const { signal } = controller;
40 process.nextTick(() => controller.abort());
98 const controller = new AbortController();
99 const { signal } = controller;
100 process.nextTick(() => controller.abort());
/third_party/node/test/fixtures/wpt/streams/readable-byte-streams/
H A Dgeneral.any.js44 let controller;
53 controller = c;
58 desiredSize = controller.desiredSize;
316 let controller;
321 controller = c;
324 const byobRequest = controller.byobRequest;
400 let controller;
405 controller = c;
408 const byobRequest = controller.byobRequest;
499 let controller;
[all...]
H A Dconstruct-byob-request.any.js10 let controller;
13 controller = c;
17 return controller;
43 const controller = createDummyObject(ReadableByteStreamController.prototype, controllerType,
48 assert_throws_js(TypeError, () => new ReadableStreamBYOBRequest(controller, view),
/third_party/node/lib/internal/webstreams/
H A Dtransformstream.js88 * @param {TransformStreamDefaultController} controller;
93 * @param {TransformStreamDefaultController} controller;
100 * @param {TransformStreamDefaultController} controller
172 this[kState].controller));
265 controller: undefined,
295 controller: readableController,
344 async function defaultTransformAlgorithm(chunk, controller) {
345 transformStreamDefaultControllerEnqueue(controller, chunk);
391 controller: undefined,
408 controller,
[all...]
H A Dutil.js149 function dequeueValue(controller) {
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);
162 function resetQueue(controller) {
163 assert(controller[kState].queue !== undefined);
164 assert(controller[kStat
[all...]
H A Dadapters.js130 let controller;
159 controller.error(error);
160 controller = undefined;
169 controller.error(new AbortError());
170 controller = undefined;
176 start(c) { controller = c; },
199 controller = undefined;
429 let controller;
435 controller.enqueue(chunk);
436 if (controller
[all...]
H A Dtransfer.js110 controller: undefined,
115 controller,
124 controller,
128 readableStreamDefaultControllerClose(controller);
132 readableStreamDefaultControllerError(controller, value);
144 this[kState].controller,
150 start(controller) {
151 this[kState].controller = controller;
178 controller
[all...]
H A Dencoding.js60 transform: (chunk, controller) => {
88 controller.enqueue(value);
91 flush: (controller) => {
94 controller.enqueue(new Uint8Array([0xEF, 0xBF, 0xBD]));
153 transform: (chunk, controller) => {
156 controller.enqueue(value);
158 flush: (controller) => {
161 controller.enqueue(value);
162 controller.terminate();
/third_party/node/deps/undici/src/lib/fetch/
H A Dindex.js97 // https://fetch.spec.whatwg.org/#fetch-controller-abort
103 // 1. Set controller’s state to "aborted".
116 // 5. Set controller’s serialized abort reason to serializedError.
174 // 10. Let controller be null.
175 let controller = null
184 // 2. Assert: controller is non-null.
185 assert(controller != null)
187 // 3. Abort controller with requestObject’s signal’s abort reason.
188 controller.abort(requestObject.signal.reason)
201 // 13. Set controller t
[all...]
/third_party/node/test/fixtures/wpt/dom/abort/resources/
H A Dabort-signal-any-tests.js1 // Tests for AbortSignal.any() and subclasses that don't use a controller.
11 // Tests for AbortSignal.any() and subclasses that use a controller.
17 const controller = new controllerInterface();
18 const signal = controller.signal;
34 controller.abort("reason string");
82 const controller = new controllerInterface();
83 const signal = signalInterface.any([controller.signal, controller.signal]);
85 controller.abort("reason");
128 const controller
[all...]
/third_party/node/test/fixtures/wpt/streams/piping/
H A Dabort.any.js15 pull(controller) {
17 controller.error('failed to abort');
120 start(controller) {
121 controller.enqueue('a');
122 controller.enqueue('b');
123 controller.close();
188 pull(controller) {
189 controller.error('failed to abort');
218 pull(controller) {
219 controller
[all...]
H A Dthen-interception.any.js26 start(controller) {
27 controller.enqueue('a');
28 controller.close();
48 start(controller) {
49 controller.enqueue('a');
50 controller.close();
H A Dpipe-through.any.js68 start(controller) {
69 controller.close();
187 const controller = new AbortController();
188 const signal = controller.signal;
220 start(controller) {
221 controller.error();
233 start(controller) {
234 controller.close();
247 start(controller) {
248 controller
[all...]
/third_party/protobuf/python/google/protobuf/internal/
H A Dservice_reflection_test.py52 def CallMethod(self, method, controller, request, response, callback):
54 self.controller = controller
113 def CallMethod(self, method, controller, request,
116 self.controller = controller
127 rpc_controller = 'controller'
139 self.assertEqual(rpc_controller, channel.controller)
/third_party/protobuf/python/compatibility_tests/v2.5.0/tests/google/protobuf/internal/
H A Dservice_reflection_test.py47 def CallMethod(self, method, controller, request, response, callback):
49 self.controller = controller
104 def CallMethod(self, method, controller, request,
107 self.controller = controller
118 rpc_controller = 'controller'
131 self.assertEqual(rpc_controller, channel.controller)
/third_party/libwebsockets/lib/drivers/button/
H A Dlws-button.c41 * button controller
49 const lws_button_controller_t *controller; member
85 * All the buttons point here and use one timer per button controller. An
112 const lws_button_controller_t *bc = bcs->controller; in LWS_PLAT_TIMER_CB()
134 * IRQ controller... in LWS_PLAT_TIMER_CB()
208 const lws_button_controller_t *bc = bcs->controller; in LWS_PLAT_TIMER_CB()
432 const lws_button_controller_t *controller) in lws_button_controller_create()
435 (controller->count_buttons * sizeof(lws_button_each_t)), in lws_button_controller_create()
443 bcs->controller = controller; in lws_button_controller_create()
431 lws_button_controller_create(struct lws_context *ctx, const lws_button_controller_t *controller) lws_button_controller_create() argument
[all...]
/third_party/libwebsockets/minimal-examples/embedded/esp32/esp-c3dev/
H A Dlws-button.c41 * button controller
49 const lws_button_controller_t *controller; member
84 * All the buttons point here and use one timer per button controller. An
108 const lws_button_controller_t *bc = bcs->controller; in LWS_PLAT_TIMER_CB()
131 * IRQ controller... in LWS_PLAT_TIMER_CB()
206 const lws_button_controller_t *bc = bcs->controller; in LWS_PLAT_TIMER_CB()
399 const lws_button_controller_t *controller) in lws_button_controller_create()
402 (controller->count_buttons * sizeof(lws_button_each_t)), in lws_button_controller_create()
410 bcs->controller = controller; in lws_button_controller_create()
398 lws_button_controller_create(struct lws_context *ctx, const lws_button_controller_t *controller) lws_button_controller_create() argument
[all...]
/third_party/node/src/tracing/
H A Dtrace_event.cc28 void TraceEventHelper::SetTracingController(v8::TracingController* controller) { in SetTracingController() argument
29 g_controller = controller; in SetTracingController()
38 void SetTracingController(v8::TracingController* controller) { in SetTracingController() argument
39 tracing::TraceEventHelper::SetTracingController(controller); in SetTracingController()

Completed in 8 milliseconds

1234