(e *Executor)
| 508 | } |
| 509 | |
| 510 | func (o *concurrencyOption) ApplyToExecutor(e *Executor) { |
| 511 | e.Concurrency = o.concurrency |
| 512 | } |
| 513 | |
| 514 | // WithInterval sets the interval at which the [Executor] will wait for |
| 515 | // duplicated events before running a task. |
nothing calls this directly
no outgoing calls
no test coverage detected