Shutdown gracefully shuts down the processor, waiting for workers to complete
(ctx context.Context)
| 184 | |
| 185 | // Shutdown gracefully shuts down the processor, waiting for workers to complete |
| 186 | func (ph *PoolHook) Shutdown(ctx context.Context) error { |
| 187 | return ph.workerManager.shutdownWorkers(ctx) |
| 188 | } |