Method Process

examples/filtering/filter.go:28–37

(l baker.Record, next func(baker.Record))

}

func (f *LazyFilter) Process(l baker.Record, next func(baker.Record)) {
	h := time.Now().Hour()
	upperLimit := 18
	if f.stakhanovite {
		upperLimit = 20
	}
	if h >= 9 && h <= upperLimit {
		next(l)
	}
}

func (f *LazyFilter) Stats() baker.FilterStats {
	return baker.FilterStats{}