| 263 | })) |
| 264 | } |
| 265 | function p(e, t, r = !0) { |
| 266 | const o = e ? i.ee.get(e) : i.ee, |
| 267 | c = s.i.handlers |
| 268 | if (!o.aborted && o.backlog && c) { |
| 269 | if ( |
| 270 | ((0, n.W)({ |
| 271 | agentIdentifier: e, |
| 272 | type: 'lifecycle', |
| 273 | name: 'drain', |
| 274 | feature: t, |
| 275 | }), |
| 276 | r) |
| 277 | ) { |
| 278 | const e = o.backlog[t], |
| 279 | r = c[t] |
| 280 | if (r) { |
| 281 | for (let t = 0; e && t < e.length; ++t) g(e[t], r) |
| 282 | Object.entries(r).forEach(([e, t]) => { |
| 283 | Object.values(t || {}).forEach((t) => { |
| 284 | t[0]?.on && |
| 285 | t[0].context() instanceof a.y && |
| 286 | !t[0].listeners(e).includes(t[1]) && |
| 287 | t[0].on(e, t[1]) |
| 288 | }) |
| 289 | }) |
| 290 | } |
| 291 | } |
| 292 | o.isolatedBacklog || delete c[t], |
| 293 | (o.backlog[t] = null), |
| 294 | o.emit('drain-' + t, []) |
| 295 | } |
| 296 | } |
| 297 | function g(e, t) { |
| 298 | var r = e[1] |
| 299 | Object.values(t[r] || {}).forEach((t) => { |