Merge pull request #9 from getoutreach/async

feat: using async like contract

looper.go

@@ -18,19 +18,19 @@ import "context"
 // ....
 // }
 type BaseLooper struct {
-	runner RunnerCloser
+	runner Runner
 }
 
 // Run executes runners workload. Pipelines are starting Run method in separated goroutine.
 // Runner must report its readiness using given callback
-func (l *BaseLooper) Run(ctx context.Context, ready ReadyFunc) error {
-	return l.runner.Run(ctx, ready)
+func (l *BaseLooper) Run(ctx context.Context) error {
+	return l.runner.Run(ctx)
 }
 
 // Close method triggers graceful shutdown on the task. It should block till task is properly closed.
 // When Close timeout is exceeded then given context is canceled.
 func (l *BaseLooper) Close(ctx context.Context) error {
-	return l.runner.Close(ctx)
+	return RunnerClose(ctx, l.runner)
 }
 
 func NewBaseLooper(looper func(ctx context.Context, loop *Loop) error) *BaseLooper {