Lines Matching refs:controller
97 // 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 to the result of calling fetch given request,
214 // abort reason given controller’s serialized abort reason and
220 abortFetch(p, request, responseObject, controller.serializedAbortReason)
246 controller = fetching({
423 controller: new Fetch(dispatcher),
520 fetchParams.controller.terminate(err)
523 // 17. Return fetchParam's controller
524 return fetchParams.controller
737 fetchParams.controller.dump = true
953 const identityTransformAlgorithm = (chunk, controller) => {
954 controller.enqueue(chunk)
1073 fetchParams.controller.connection.destroy()
1559 fetchParams.controller.connection.destroy()
1583 assert(!fetchParams.controller.connection || fetchParams.controller.connection.destroyed)
1585 fetchParams.controller.connection = {
1733 // 2. If e is an "AbortError" DOMException, then abort fetchParams’s controller.
1735 fetchParams.controller.abort()
1737 fetchParams.controller.terminate(e)
1763 fetchParams.controller.next = () => iterator.next()
1771 fetchParams.controller.connection.destroy()
1783 fetchParams.controller.resume()
1787 // controller with reason, given reason.
1789 fetchParams.controller.abort(reason)
1810 async start (controller) {
1811 fetchParams.controller.controller = controller
1813 async pull (controller) {
1814 await pullAlgorithm(controller)
1850 fetchParams.controller.on('terminated', onAborted)
1851 fetchParams.controller.resume = async () => {
1861 const { done, value } = await fetchParams.controller.next()
1869 if (fetchParams.controller.ended && !timingInfo.encodedBodySize) {
1886 readableStreamClose(fetchParams.controller.controller)
1896 // 6. If bytes is failure, then terminate fetchParams’s controller.
1898 fetchParams.controller.terminate(bytes)
1904 fetchParams.controller.controller.enqueue(new Uint8Array(bytes))
1908 fetchParams.controller.terminate()
1914 if (!fetchParams.controller.controller.desiredSize) {
1929 // controller’s serialized abort reason and an
1932 fetchParams.controller.controller.error(
1933 fetchParams.controller.serializedAbortReason
1939 fetchParams.controller.controller.error(new TypeError('terminated', {
1947 fetchParams.controller.connection.destroy()
1956 const agent = fetchParams.controller.dispatcher
1963 body: fetchParams.controller.dispatcher.isMockActive ? request.body && (request.body.source || request.body.stream) : body,
1974 const { connection } = fetchParams.controller
1979 fetchParams.controller.on('terminated', abort)
2071 if (fetchParams.controller.dump) {
2095 fetchParams.controller.off('terminated', this.abort)
2098 fetchParams.controller.ended = true
2105 fetchParams.controller.off('terminated', this.abort)
2110 fetchParams.controller.terminate(error)