()
| 149 | let ended = false; |
| 150 | |
| 151 | const endSpanOnce = (): void => { |
| 152 | if (ended) return; |
| 153 | |
| 154 | ended = true; |
| 155 | span.end(); |
| 156 | waitUntil?.(flushAndDispose(client)); |
| 157 | }; |
| 158 | |
| 159 | const transform = new TransformStream({ |
| 160 | flush() { |
no test coverage detected