|
@@ -9,6 +9,7 @@ package depager
|
|
|
import (
|
|
|
"context"
|
|
|
"fmt"
|
|
|
+ "io"
|
|
|
)
|
|
|
|
|
|
/*
|
|
@@ -148,7 +149,9 @@ func (p *pager[T]) IterPages() <-chan Page[T] {
|
|
|
break
|
|
|
}
|
|
|
if p.err != nil {
|
|
|
- p.err = fmt.Errorf("pager: iterate pages: %w", p.err)
|
|
|
+ if p.err != io.EOF {
|
|
|
+ p.err = fmt.Errorf("pager: iterate pages: %w", p.err)
|
|
|
+ }
|
|
|
p.pagePool <- page
|
|
|
return
|
|
|
}
|
|
@@ -173,7 +176,9 @@ func (p *pager[T]) Iter() <-chan T {
|
|
|
}
|
|
|
p.pagePool <- page
|
|
|
if p.err != nil {
|
|
|
- p.err = fmt.Errorf("pager: iterate items: %w", p.err)
|
|
|
+ if p.err != io.EOF {
|
|
|
+ p.err = fmt.Errorf("pager: iterate items: %w", p.err)
|
|
|
+ }
|
|
|
return
|
|
|
}
|
|
|
}
|