(streamId: string)
| 243 | } |
| 244 | |
| 245 | export async function clearAbortMarker(streamId: string): Promise<void> { |
| 246 | await withRedisRetry({ operation: 'clear_abort_marker', streamId }, async (redis) => { |
| 247 | await redis.del(getAbortKey(streamId)) |
| 248 | }) |
| 249 | } |
no test coverage detected