File tree 2 files changed +3
-3
lines changed
2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -69,8 +69,8 @@ var _ Source = &channel[string]{}
69
69
// ChannelOpt allows to configure a source.Channel.
70
70
type ChannelOpt [T any ] func (* channel [T ])
71
71
72
- // WithPrededicates adds the configured predicates to a source.Channel.
73
- func WithPrededicates [T any ](p ... predicate.TypedPredicate [T ]) ChannelOpt [T ] {
72
+ // WithPredicates adds the configured predicates to a source.Channel.
73
+ func WithPredicates [T any ](p ... predicate.TypedPredicate [T ]) ChannelOpt [T ] {
74
74
return func (c * channel [T ]) {
75
75
c .predicates = append (c .predicates , p ... )
76
76
}
Original file line number Diff line number Diff line change @@ -318,7 +318,7 @@ var _ = Describe("Source", func() {
318
318
close (c )
319
319
},
320
320
},
321
- source .WithPrededicates (prct ),
321
+ source .WithPredicates (prct ),
322
322
)
323
323
err := instance .Start (ctx , q )
324
324
Expect (err ).NotTo (HaveOccurred ())
You can’t perform that action at this time.
0 commit comments