diff options
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 { |