(event: string, now: number, maxQueueSize: number)
| 153 | }; |
| 154 | |
| 155 | const emitSnapshot = (event: string, now: number, maxQueueSize: number): void => { |
| 156 | lastSnapshotEmittedAt = now; |
| 157 | console.log( |
| 158 | `${LOG_PREFIX} ${JSON.stringify({ |
| 159 | event, |
| 160 | ...snapshot(now, maxQueueSize), |
| 161 | })}`, |
| 162 | ); |
| 163 | }; |
| 164 | |
| 165 | const maybeEmitPeriodicSnapshot = (now: number, maxQueueSize: number): void => { |
| 166 | if (now - lastSnapshotEmittedAt < PERIODIC_EMIT_INTERVAL_MS) return; |
no test coverage detected