(streamId: string)
| 95 | } |
| 96 | |
| 97 | export async function resetBuffer(streamId: string): Promise<void> { |
| 98 | await clearBuffer(streamId, 'reset_outbox') |
| 99 | } |
| 100 | |
| 101 | export async function clearBuffer(streamId: string, operation = 'clear_outbox'): Promise<void> { |
| 102 | await withRedisRetry({ operation, streamId }, async (redis) => { |