()
| 147 | // survive request termination. |
| 148 | export const installTracerProvider = (): boolean => ensureGlobalTracerProvider(); |
| 149 | export const flushTracerProvider = async (): Promise<void> => { |
| 150 | if (!provider) return; |
| 151 | const startedAt = Date.now(); |
| 152 | // oxlint-disable-next-line executor/no-try-catch-or-throw -- observability boundary; preserve forceFlush failure behavior while counting it |
| 153 | try { |
| 154 | await provider.forceFlush(); |
| 155 | recordForceFlush(Date.now() - startedAt, false); |
| 156 | } catch (error) { |
| 157 | recordForceFlush(Date.now() - startedAt, true); |
| 158 | // oxlint-disable-next-line executor/no-try-catch-or-throw -- preserve original rejection for waitUntil diagnostics |
| 159 | throw error; |
| 160 | } |
| 161 | }; |
| 162 | |
| 163 | const makeTelemetryLive = (): Layer.Layer<never> => |
| 164 | Layer.mergeAll( |
no test coverage detected