Skip to content

Commit 5af5561

Browse files
committed
Removed the source queue and pulled object from the channel
1 parent d36d011 commit 5af5561

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

singleton/controller.go

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -39,12 +39,10 @@ func AsChannelObjectReconciler[T client.Object](watchEvents <-chan watch.Event,
3939
return reconcile.Func(func(ctx context.Context, r reconcile.Request) (reconcile.Result, error) {
4040
var errs error
4141
var results []reconcile.Result
42-
for event := range watchEvents {
43-
res, err := reconciler.Reconcile(ctx, event.Object.(T))
44-
errs = multierr.Append(errs, err)
45-
results = append(results, res)
46-
47-
}
42+
e := <-watchEvents
43+
res, err := reconciler.Reconcile(ctx, e.Object.(T))
44+
errs = multierr.Append(errs, err)
45+
results = append(results, res)
4846

4947
var result reconcile.Result
5048
min := time.Duration(math.MaxInt64)

0 commit comments

Comments
 (0)