Lines Matching defs:channels
111 const channels = {}
115 channels.sendHeaders = diagnosticsChannel.channel('undici:client:sendHeaders')
116 channels.beforeConnect = diagnosticsChannel.channel('undici:client:beforeConnect')
117 channels.connectError = diagnosticsChannel.channel('undici:client:connectError')
118 channels.connected = diagnosticsChannel.channel('undici:client:connected')
120 channels.sendHeaders = { hasSubscribers: false }
121 channels.beforeConnect = { hasSubscribers: false }
122 channels.connectError = { hasSubscribers: false }
123 channels.connected = { hasSubscribers: false }
1183 if (channels.beforeConnect.hasSubscribers) {
1184 channels.beforeConnect.publish({
1276 if (channels.connected.hasSubscribers) {
1277 channels.connected.publish({
1298 if (channels.connectError.hasSubscribers) {
1299 channels.connectError.publish({
1603 if (channels.sendHeaders.hasSubscribers) {
1604 channels.sendHeaders.publish({ request, headers: header, socket })