Условие
const MaxItems = 9999
type Producer interface {
// Next returns:
// - batch of items to be processed
// - cookie to be committed when processing if finished
// - error
Next() (items []any, cookie int, err error)
// Commit is used to mark data batch as
Commit(cookie int) error
}
type Consumer interface {
Process(items []any) error
}
func Pipe(p Producer, c Consumer) error {
// TODO
}1. Задача: Реализовать функцию Pipe для чтения данных из источника, группировки их в буфер и сохранения в приемник с последующей фиксацией прогресса
Комментарий кандидата. Нам нужно передать данные из…