go pipe

pipe.go 源码

// Copyright © 2018 Inanc Gumus
// Learn Go Programming Course
// License: https://creativecommons.org/licenses/by-nc-sa/4.0/
//
// For more tutorials  : https://learngoprogramming.com
// In-person training  : https://www.linkedin.com/in/inancgumus/
// Follow me on twitter: https://twitter.com/inancgumus

package pipe

// Iterator yields a record.
type Iterator interface {
	Each(func(Record) error) error
}

// Consumer consumes records from an iterator.
type Consumer interface {
	Consume(Iterator) error
}

// Transform represents both a record consumer and producer.
// It has an input and output.
// It takes a single record and provides an iterator for all the records.
type Transform interface {
	Iterator // producer: should never return on yield().err == nil
	Consumer
}