(rcptTo string, err error)
| 446 | } |
| 447 | |
| 448 | func (sc statusCollector) SetStatus(rcptTo string, err error) { |
| 449 | original, ok := sc.originalRcpts[rcptTo] |
| 450 | if ok { |
| 451 | rcptTo = original |
| 452 | } |
| 453 | sc.wrapped.SetStatus(rcptTo, err) |
| 454 | } |
| 455 | |
| 456 | func (dd *msgpipelineDelivery) BodyNonAtomic(ctx context.Context, c module.StatusCollector, header textproto.Header, body buffer.Buffer) { |
| 457 | setStatusAll := func(err error) { |