in pkg/journal/loader.go [64:78]
func splitYAML(data []byte, atEOF bool) (advance int, token []byte, err error) {
if atEOF && len(data) == 0 {
return 0, nil, nil
}
if i := bytes.Index(data, yamlSep); i >= 0 {
// We have a full object.
return i + len(yamlSep), data[0:i], nil
}
// If we're at EOF, we have a final, non-terminated object. Return it.
if atEOF {
return len(data), data, nil
}
// Request more data.
return 0, nil, nil
}