Method writeEvent

service/eventstream.go:24–38

(ev event)

}

func (e *eventStreamWriter) writeEvent(ev event) error {
	var buf bytes.Buffer
	w, err := anyio.NewWriter(sio.NopCloser(&buf), anyio.WriterOpts{Format: e.format})
	if err != nil {
		return err
	}
	if err := w.Push(sbuf.ValToVec(super.NewContext(), ev.value)); err != nil {
		return err
	}
	if err := w.Close(); err != nil {
		return err
	}
	_, err = fmt.Fprintf(e.body, "event: %s\ndata: %s\n\n", ev.name, &buf)
	return err
}