csv

Documentation

Index

• func FromReader(r *csv.Reader, opt ...rivo.Option) rivo.Pipeline[rivo.None, []string]
• func ToWriter(w *csv.Writer, opts ...rivo.Option) rivo.Pipeline[[]string, struct{}]

Functions

func FromReader

func FromReader(r *csv.Reader, opt ...rivo.Option) rivo.Pipeline[rivo.None, []string]

FromReader returns a generator pipeline that reads from a csv.Reader. It's not thread-safe to use a pool size greater than 1.

func ToWriter

func ToWriter(w *csv.Writer, opts ...rivo.Option) rivo.Pipeline[[]string, struct{}]

ToWriter returns a pipeline that writes to a csv.Writer. Only errors from the csv.Writer are passed to the output stream.