268
// Note that calling MustOffer is the only way that matcher knows there are spooled tasks in the
269
// backlog, in absence of a pending MustOffer call, the forwarding logic assumes that backlog is empty.
270
>
func (tm *TaskMatcher) MustOffer(ctx context.Context, task *internalTask, interruptCh <-chan struct{}) error {
matcher.go
271
>
tm.registerBacklogTask(task)
272
>
defer tm.unregisterBacklogTask(task)
273
>
274
>
if err := tm.rateLimiter.Wait(ctx); err != nil {
275
return err
276
}