diff --git a/internal/transport/delivery/delivery.go b/internal/transport/delivery/delivery.go index d934cd514..286f2abd2 100644 --- a/internal/transport/delivery/delivery.go +++ b/internal/transport/delivery/delivery.go @@ -123,8 +123,6 @@ func (p *WorkerPool) Start(n int) { // false = already running. _ = p.workers[i].Start() } - - return } // Stop will attempt to stop contained Worker{}s. @@ -147,7 +145,6 @@ func (p *WorkerPool) Stop() { // Unset workers slice. p.workers = p.workers[:0] - return } // Worker wraps an httpclient.Client{} to feed diff --git a/internal/workers/worker_fn.go b/internal/workers/worker_fn.go index 9fa6d8e6a..c41bee2b0 100644 --- a/internal/workers/worker_fn.go +++ b/internal/workers/worker_fn.go @@ -61,8 +61,6 @@ func (p *FnWorkerPool) Start(n int) { // false = already running. _ = p.workers[i].Start() } - - return } // Stop will attempt to stop contained FnWorker{}s. @@ -85,7 +83,6 @@ func (p *FnWorkerPool) Stop() { // Unset workers slice. p.workers = p.workers[:0] - return } // FnWorker wraps a queue.SimpleQueue{} which diff --git a/internal/workers/worker_msg.go b/internal/workers/worker_msg.go index fc418c12c..1920c964e 100644 --- a/internal/workers/worker_msg.go +++ b/internal/workers/worker_msg.go @@ -71,8 +71,6 @@ func (p *MsgWorkerPool[T]) Start(n int) { // false = already running. _ = p.workers[i].Start() } - - return } // Stop will attempt to stop contained Worker{}s. @@ -95,7 +93,6 @@ func (p *MsgWorkerPool[T]) Stop() { // Unset workers slice. p.workers = p.workers[:0] - return } // MsgWorker wraps a processing function to