Method ReadAll

pkg/utilds/multireaderlinebuffer.go:38–45

(r io.Reader)

}

func (mrlb *MultiReaderLineBuffer) ReadAll(r io.Reader) {
	scanner := bufio.NewScanner(r)
	for scanner.Scan() {
		line := scanner.Text()
		mrlb.addLine(line)
		mrlb.callLineCallback(line)
	}
}

func (mrlb *MultiReaderLineBuffer) callLineCallback(line string) {
	mrlb.lock.Lock()