diff options
author | Valery Piashchynski <[email protected]> | 2020-11-26 12:44:12 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2020-11-26 12:44:12 +0300 |
commit | 574f351aaecdee1176b9700bb6d7eb61fe170906 (patch) | |
tree | 6271704950d2c89a43de3edafb677a003d50a406 /sync_worker.go | |
parent | e5313529e4293b7ad985cce72cec54b08462259d (diff) |
Remove context from worker wait function. Explicitly enable ubuntu 20.04
in the CI
Diffstat (limited to 'sync_worker.go')
-rwxr-xr-x | sync_worker.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/sync_worker.go b/sync_worker.go index 6f5b20d9..cd0f934e 100755 --- a/sync_worker.go +++ b/sync_worker.go @@ -17,7 +17,6 @@ var EmptyPayload = Payload{} type SyncWorker interface { // WorkerBase provides basic functionality for the SyncWorker WorkerBase - // Exec used to execute payload on the SyncWorker, there is no TIMEOUTS Exec(rqs Payload) (Payload, error) // ExecWithContext used to handle Exec with TTL @@ -28,6 +27,7 @@ type syncWorker struct { w WorkerBase } +// NewSyncWorker creates SyncWorker from WorkerBasa func NewSyncWorker(w WorkerBase) (SyncWorker, error) { return &syncWorker{ w: w, @@ -191,8 +191,8 @@ func (tw *syncWorker) Start() error { return tw.w.Start() } -func (tw *syncWorker) Wait(ctx context.Context) error { - return tw.w.Wait(ctx) +func (tw *syncWorker) Wait() error { + return tw.w.Wait() } func (tw *syncWorker) Stop(ctx context.Context) error { |