diagnostics-channel: use not deprecated subscribe fn

nodejs · Sep 13, 2024 · b5e7c93 · b5e7c93
1 parent 0b287b9
commit b5e7c93
Showing 1 changed file with 25 additions and 12 deletions.
diff --git a/lib/core/diagnostics.js b/lib/core/diagnostics.js
@@ -1,4 +1,5 @@
 'use strict'
+
 const diagnosticsChannel = require('node:diagnostics_channel')
 const util = require('node:util')
 
@@ -35,7 +36,8 @@ function trackClientEvents (debugLog = undiciDebugLog) {
 
   isTrackingClientEvents = true
 
-  diagnosticsChannel.channel('undici:client:beforeConnect').subscribe(evt => {
+  diagnosticsChannel.subscribe('undici:client:beforeConnect', 
+    evt => {
     const {
       connectParams: { version, protocol, port, host }
     } = evt
@@ -48,7 +50,8 @@ function trackClientEvents (debugLog = undiciDebugLog) {
     )
   })
 
-  diagnosticsChannel.channel('undici:client:connected').subscribe(evt => {
+  diagnosticsChannel.subscribe('undici:client:connected', 
+    evt => {
     const {
       connectParams: { version, protocol, port, host }
     } = evt
@@ -61,7 +64,8 @@ function trackClientEvents (debugLog = undiciDebugLog) {
     )
   })
 
-  diagnosticsChannel.channel('undici:client:connectError').subscribe(evt => {
+  diagnosticsChannel.subscribe('undici:client:connectError', 
+    evt => {
     const {
       connectParams: { version, protocol, port, host },
       error
@@ -76,7 +80,8 @@ function trackClientEvents (debugLog = undiciDebugLog) {
     )
   })
 
-  diagnosticsChannel.channel('undici:client:sendHeaders').subscribe(evt => {
+  diagnosticsChannel.subscribe('undici:client:sendHeaders', 
+    evt => {
     const {
       request: { method, path, origin }
     } = evt
@@ -93,7 +98,8 @@ function trackRequestEvents (debugLog = undiciDebugLog) {
 
   isTrackingRequestEvents = true
 
-  diagnosticsChannel.channel('undici:request:headers').subscribe(evt => {
+  diagnosticsChannel.subscribe('undici:request:headers', 
+    evt => {
     const {
       request: { method, path, origin },
       response: { statusCode }
@@ -107,14 +113,16 @@ function trackRequestEvents (debugLog = undiciDebugLog) {
     )
   })
 
-  diagnosticsChannel.channel('undici:request:trailers').subscribe(evt => {
+  diagnosticsChannel.subscribe('undici:request:trailers', 
+    evt => {
     const {
       request: { method, path, origin }
     } = evt
     debugLog('trailers received from %s %s/%s', method, origin, path)
   })
 
-  diagnosticsChannel.channel('undici:request:error').subscribe(evt => {
+  diagnosticsChannel.subscribe('undici:request:error', 
+    evt => {
     const {
       request: { method, path, origin },
       error
@@ -138,14 +146,16 @@ function trackWebSocketEvents (debugLog = websocketDebuglog) {
 
   isTrackingWebSocketEvents = true
 
-  diagnosticsChannel.channel('undici:websocket:open').subscribe(evt => {
+  diagnosticsChannel.subscribe('undici:websocket:open', 
+    evt => {
     const {
       address: { address, port }
     } = evt
     debugLog('connection opened %s%s', address, port ? `:${port}` : '')
   })
 
-  diagnosticsChannel.channel('undici:websocket:close').subscribe(evt => {
+  diagnosticsChannel.subscribe('undici:websocket:close', 
+    evt => {
     const { websocket, code, reason } = evt
     debugLog(
       'closed connection to %s - %s %s',
@@ -155,15 +165,18 @@ function trackWebSocketEvents (debugLog = websocketDebuglog) {
     )
   })
 
-  diagnosticsChannel.channel('undici:websocket:socket_error').subscribe(err => {
+  diagnosticsChannel.subscribe('undici:websocket:socket_error', 
+    err => {
     debugLog('connection errored - %s', err.message)
   })
 
-  diagnosticsChannel.channel('undici:websocket:ping').subscribe(evt => {
+  diagnosticsChannel.subscribe('undici:websocket:ping', 
+    evt => {
     debugLog('ping received')
   })
 
-  diagnosticsChannel.channel('undici:websocket:pong').subscribe(evt => {
+  diagnosticsChannel.subscribe('undici:websocket:pong', 
+    evt => {
     debugLog('pong received')
   })
 }