(payload types.MessagePayload, title, body string, helpers template.FuncMap)
| 531 | } |
| 532 | |
| 533 | func (bh *barrierHandler) Dispatcher(payload types.MessagePayload, title, body string, helpers template.FuncMap) (dispatch.DeliveryFunc, error) { |
| 534 | deliverFn, err := bh.h.Dispatcher(payload, title, body, helpers) |
| 535 | if err != nil { |
| 536 | return nil, err |
| 537 | } |
| 538 | |
| 539 | return func(ctx context.Context, msgID uuid.UUID) (retryable bool, err error) { |
| 540 | bh.wg.Wait() |
| 541 | |
| 542 | return deliverFn(ctx, msgID) |
| 543 | }, nil |
| 544 | } |
nothing calls this directly
no test coverage detected