XXX
This commit is contained in:
parent
6cb4dc0ca8
commit
6dab63b3c0
3
tail.go
3
tail.go
|
@ -170,7 +170,7 @@ func (tail *Tail) reopen() error {
|
||||||
func (tail *Tail) readLine() ([]byte, error) {
|
func (tail *Tail) readLine() ([]byte, error) {
|
||||||
line, isPrefix, err := tail.reader.ReadLine()
|
line, isPrefix, err := tail.reader.ReadLine()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return line, err
|
||||||
}
|
}
|
||||||
|
|
||||||
// If MaxLineSize is set, we don't have to join the parts (let
|
// If MaxLineSize is set, we don't have to join the parts (let
|
||||||
|
@ -244,6 +244,7 @@ func (tail *Tail) tailFileSync() {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
case io.EOF:
|
case io.EOF:
|
||||||
|
// XXX: should `line` be returned at this point?
|
||||||
if !tail.Follow {
|
if !tail.Follow {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue