fix(helper/stream): fix function type

modernice · Jul 15, 2022 · c6d43c0 · c6d43c0
1 parent 4d3b19f
commit c6d43c0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/helper/streams/streams.go b/helper/streams/streams.go
@@ -68,9 +68,9 @@ func Concurrent[T any](c chan T) func(context.Context, ...T) error {
 
 // NewConcurrentContext does the same as NewConcurrent, but uses the provided
 // Context for every push call.
-func NewConcurrentContext[T any](ctx context.Context, vals ...T) (_ <-chan T, _push func(context.Context, ...T) error, _close func()) {
+func NewConcurrentContext[T any](ctx context.Context, vals ...T) (_ <-chan T, _push func(...T) error, _close func()) {
 	out, push, cls := NewConcurrent(vals...)
-	return out, func(_ context.Context, vals ...T) error {
+	return out, func(vals ...T) error {
 		return push(ctx, vals...)
 	}, cls
 }