feat: support task options for pipe.Tap

hiroara · Aug 2, 2023 · 27b2ac7 · 27b2ac7
1 parent 7e8a078
commit 27b2ac7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pipe/tap.go b/pipe/tap.go
@@ -21,15 +21,15 @@ func Tap[S any](fn TapFn[S]) *TapOp[S] {
 }
 
 // Convert the tap operator as a Pipe.
-func (op *TapOp[S]) AsPipe() Pipe[S, S] {
+func (op *TapOp[S]) AsPipe(opts ...task.Option) Pipe[S, S] {
 	return Map(func(ctx context.Context, el S) (S, error) {
 		var zero S
 		err := op.run(ctx, el)
 		if err != nil {
 			return zero, err
 		}
 		return el, nil
-	}).AsPipe()
+	}).AsPipe(opts...)
 }
 
 // Convert the tap operator as a task.