( thread: ThreadData, reason: RuntimeThreadReason | 'external', )
| 202 | } |
| 203 | |
| 204 | export function normalizeThreadDataForReason( |
| 205 | thread: ThreadData, |
| 206 | reason: RuntimeThreadReason | 'external', |
| 207 | ): ThreadData { |
| 208 | if (reason === 'compaction-start') { |
| 209 | return setThreadCompactingState(thread, true) |
| 210 | } |
| 211 | |
| 212 | if (reason !== 'end' && reason !== 'external' && reason !== 'compaction') { |
| 213 | return thread |
| 214 | } |
| 215 | |
| 216 | return setThreadCompactingState(setThreadStreamingState(thread, false), false) |
| 217 | } |
| 218 | |
| 219 | async function hasPersistedSessionFile(sessionPath: string) { |
| 220 | try { |
no test coverage detected