()
| 108 | } |
| 109 | |
| 110 | flushSync(): void { |
| 111 | const deadline = Date.now() + 200; |
| 112 | this.globalSink?.flushSync(); |
| 113 | for (const entry of this.sessions.values()) { |
| 114 | if (entry.state !== 'open') continue; |
| 115 | if (Date.now() > deadline) break; |
| 116 | entry.sink.flushSync(); |
| 117 | } |
| 118 | } |
| 119 | |
| 120 | emit(entry: LogEntry): void { |
| 121 | const config = this.config; |