setupResponseListeners() — fastify Function Reference

Architecture documentation for the setupResponseListeners() function in reply.js from the fastify codebase.

Function javascript CoreKernel LifecycleManager calls 1

Entity Profile

CoreKernel→ LifecycleManager→ setupResponseListeners() — fastify Function Reference

Dependency Diagram

graph TD
  3312a7d2_5a44_4c4d_a8a7_8d1bc568b4c3["setupResponseListeners()"]
  4bcd71dc_1ec2_5fe8_b8ff_4a371e392925["reply.js"]
  3312a7d2_5a44_4c4d_a8a7_8d1bc568b4c3 -->|defined in| 4bcd71dc_1ec2_5fe8_b8ff_4a371e392925
  622c48bc_586a_8676_332c_4ea39a6d4117["onResponseCallback()"]
  3312a7d2_5a44_4c4d_a8a7_8d1bc568b4c3 -->|calls| 622c48bc_586a_8676_332c_4ea39a6d4117
  style 3312a7d2_5a44_4c4d_a8a7_8d1bc568b4c3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

lib/reply.js lines 885–909

function setupResponseListeners (reply) {
  reply[kReplyStartTime] = now()

  const onResFinished = err => {
    reply[kReplyEndTime] = now()
    reply.raw.removeListener('finish', onResFinished)
    reply.raw.removeListener('error', onResFinished)

    const ctx = reply[kRouteContext]

    if (ctx && ctx.onResponse !== null) {
      onResponseHookRunner(
        ctx.onResponse,
        reply.request,
        reply,
        onResponseCallback
      )
    } else {
      onResponseCallback(err, reply.request, reply)
    }
  }

  reply.raw.on('finish', onResFinished)
  reply.raw.on('error', onResFinished)
}