File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Expand file tree Collapse file tree 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]{}
6969// ChannelOpt allows to configure a source.Channel.
7070type ChannelOpt [T any ] func (* channel [T ])
7171
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 ] {
7474 return func (c * channel [T ]) {
7575 c .predicates = append (c .predicates , p ... )
7676 }
Original file line number Diff line number Diff line change @@ -318,7 +318,7 @@ var _ = Describe("Source", func() {
318318 close (c )
319319 },
320320 },
321- source .WithPrededicates (prct ),
321+ source .WithPredicates (prct ),
322322 )
323323 err := instance .Start (ctx , q )
324324 Expect (err ).NotTo (HaveOccurred ())
You can’t perform that action at this time.
0 commit comments