diff options
Diffstat (limited to 'example/policies.go')
| -rw-r--r-- | example/policies.go | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/example/policies.go b/example/policies.go index 50a4e07..7a81359 100644 --- a/example/policies.go +++ b/example/policies.go @@ -5,18 +5,17 @@ package main import ( "context" "errors" - "github.com/neonxp/rutina" "log" "time" + + "github.com/neonxp/rutina" ) func main() { // New instance with builtin context r := rutina.New() - errsChan := make(chan error, 1) - - r = r.With(rutina.WithErrChan(errsChan)) + r = r.With(rutina.WithErrChan()) r.Go(func(ctx context.Context) error { <-time.After(1 * time.Second) @@ -54,7 +53,7 @@ func main() { case <-ctx.Done(): log.Println("Shutdown chan listener") return nil - case err := <-errsChan: + case err := <-r.Errors(): log.Printf("Error in chan: %v", err) } } |