in pkg/output/simulate/simulate.go [101:120]
func (r *Output) Close() error {
inputEvents := &inputEvents{Events: r.events}
jsonBytes, err := json.Marshal(inputEvents)
if err != nil {
return err
}
_, err = r.pWriteCloser.Write(jsonBytes)
if err != nil {
return err
}
_, err = r.pWriteCloser.Write([]byte("\n"))
if err != nil {
return err
}
return r.pWriteCloser.Close()
}