diff options
| -rw-r--r-- | skate/cmd/skate-map/main.go | 4 | ||||
| -rw-r--r-- | skate/map.go | 7 |
2 files changed, 6 insertions, 5 deletions
diff --git a/skate/cmd/skate-map/main.go b/skate/cmd/skate-map/main.go index ee02875..2517878 100644 --- a/skate/cmd/skate-map/main.go +++ b/skate/cmd/skate-map/main.go @@ -21,8 +21,8 @@ // be skipped, if we limit number of splits) // (3) we pass the data to jq, with a bit larger buffer (default is 1MB) // (4) we want no "null" output -// (5) tostring prints input as string, because we need to carry the document forward -// (6) but we need some cleanup, too +// (5) tostring prints the input as string, because we need to carry the document forward ... +// (6) ... but we'll need some cleanup, too // (7) we normalize the DOI to lowercase // (8) a custom filter to normalize a DOI in a specific column // (9) sorting by DOI diff --git a/skate/map.go b/skate/map.go index 094d3e2..1d6bc0b 100644 --- a/skate/map.go +++ b/skate/map.go @@ -42,11 +42,12 @@ type Mapper func([]byte) ([][]byte, error) // AsTSV serializes the result of a field mapper as TSV. This is a slim // adapter, e.g. to parallel.Processor, which expects this function signature. -// If the last byte of the last field is not a newline, it will be appended. +// A newline will be appended, if not there already. func (f Mapper) AsTSV(p []byte) ([]byte, error) { var ( fields [][]byte err error + b []byte ) if fields, err = f(p); err != nil { return nil, err @@ -54,14 +55,14 @@ func (f Mapper) AsTSV(p []byte) ([]byte, error) { if len(fields) == 0 { return nil, nil } - b := bytes.Join(fields, bTab) + b = bytes.Join(fields, bTab) if len(b) > 0 && !bytes.HasSuffix(b, bNewline) { b = append(b, bNewline...) } return b, nil } -// WithPrefix adds a given prefix to the first element. +// WithPrefix is a "mapper middleware", adding a given prefix to the first field. func WithPrefix(f Mapper, prefix string) Mapper { return func(p []byte) ([][]byte, error) { fields, err := f(p) |