33 lines
747 B
Go
33 lines
747 B
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 main
|
|
|
|
import (
|
|
"github.com/inancgumus/learngo/logparser/v5/pipe"
|
|
)
|
|
|
|
type passThrough struct {
|
|
pipe.Iterator
|
|
}
|
|
|
|
func (t *passThrough) Consume(results pipe.Iterator) error {
|
|
t.Iterator = results
|
|
return nil
|
|
}
|
|
|
|
func (t *passThrough) Each(yield func(pipe.Record) error) error {
|
|
pass := func(r pipe.Record) error {
|
|
// fmt.Println(r.Fields())
|
|
// fmt.Println(r.Int("visits"))
|
|
return yield(r)
|
|
}
|
|
|
|
return t.Iterator.Each(pass)
|
|
}
|