aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/undici/lib/dispatcher/dispatcher.js
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--node_modules/undici/lib/dispatcher/dispatcher.js65
1 files changed, 0 insertions, 65 deletions
diff --git a/node_modules/undici/lib/dispatcher/dispatcher.js b/node_modules/undici/lib/dispatcher/dispatcher.js
deleted file mode 100644
index b1e0098..0000000
--- a/node_modules/undici/lib/dispatcher/dispatcher.js
+++ /dev/null
@@ -1,65 +0,0 @@
-'use strict'
-const EventEmitter = require('node:events')
-
-class Dispatcher extends EventEmitter {
- dispatch () {
- throw new Error('not implemented')
- }
-
- close () {
- throw new Error('not implemented')
- }
-
- destroy () {
- throw new Error('not implemented')
- }
-
- compose (...args) {
- // So we handle [interceptor1, interceptor2] or interceptor1, interceptor2, ...
- const interceptors = Array.isArray(args[0]) ? args[0] : args
- let dispatch = this.dispatch.bind(this)
-
- for (const interceptor of interceptors) {
- if (interceptor == null) {
- continue
- }
-
- if (typeof interceptor !== 'function') {
- throw new TypeError(`invalid interceptor, expected function received ${typeof interceptor}`)
- }
-
- dispatch = interceptor(dispatch)
-
- if (dispatch == null || typeof dispatch !== 'function' || dispatch.length !== 2) {
- throw new TypeError('invalid interceptor')
- }
- }
-
- return new ComposedDispatcher(this, dispatch)
- }
-}
-
-class ComposedDispatcher extends Dispatcher {
- #dispatcher = null
- #dispatch = null
-
- constructor (dispatcher, dispatch) {
- super()
- this.#dispatcher = dispatcher
- this.#dispatch = dispatch
- }
-
- dispatch (...args) {
- this.#dispatch(...args)
- }
-
- close (...args) {
- return this.#dispatcher.close(...args)
- }
-
- destroy (...args) {
- return this.#dispatcher.destroy(...args)
- }
-}
-
-module.exports = Dispatcher