Method Do

linebuffer/linebuffer.go:40–72

(x func(string) error)

}

func (lb *LineBuffer) Do(x func(string) error) error {
	lb.lock.Lock()
	defer lb.lock.Unlock()

	var err error

	if len(lb.lines) < lb.Size {
		for _, l := range lb.lines {
			err = x(l)
			if err != nil {
				return err
			}
		}

		return nil
	}

	for i := lb.cur; i < lb.Size; i++ {
		err = x(lb.lines[i])
		if err != nil {
			return err
		}
	}

	for i := 0; i < lb.cur; i++ {
		err = x(lb.lines[i])
		if err != nil {
			return err
		}
	}

	return nil
}

func (lb *LineBuffer) WriteTo(w io.Writer) (int64, error) {
	var tot int64