Method SetOutputChannel

input/inpututils/compressedstream.go:208–210

(data chan<- *baker.Data)

}

func (s *CompressedInput) SetOutputChannel(data chan<- *baker.Data) {
	s.data = data
}

func (s *CompressedInput) send(data *baker.Data) {
	nlines := int64(bytes.Count(data.Bytes, []byte{'\n'}))