flashmob.go-guerrilla/backends/s_process.go

package backends

import (
	"bytes"
	"github.com/flashmob/go-guerrilla/mail"
	"io"
)

func init() {
	streamers["process"] = func() *StreamDecorator {
		return StreamProcess()
	}
}

// Buffers to envelope.Data so that processors can be called on it at the end
func StreamProcess() *StreamDecorator {
	sd := &StreamDecorator{}
	sd.p =

		func(sp StreamProcessor) StreamProcessor {
			var envelope *mail.Envelope
			sd.Open = func(e *mail.Envelope) error {
				envelope = e
				return nil
			}

			return StreamProcessWith(func(p []byte) (int, error) {
				tr := io.TeeReader(bytes.NewReader(p), sp)
				n, err := envelope.Data.ReadFrom(tr)
				return int(n), err
			})
		}

	return sd
}