|
@@ -107,7 +107,7 @@ func (p *pager[T]) iteratePages() <-chan Page[T] {
|
|
|
defer close(ch)
|
|
|
var page Page[T]
|
|
|
for {
|
|
|
- if p.pctx.Err() != nil {
|
|
|
+ if p.ctx.Err() != nil {
|
|
|
break
|
|
|
}
|
|
|
page = <-p.pagePool
|
|
@@ -143,7 +143,7 @@ func (p *pager[T]) IterPages() <-chan Page[T] {
|
|
|
defer close(p.done)
|
|
|
defer close(ch)
|
|
|
for page := range p.iteratePages() {
|
|
|
- if p.pctx.Err() != nil {
|
|
|
+ if p.ctx.Err() != nil {
|
|
|
p.pagePool <- page
|
|
|
break
|
|
|
}
|
|
@@ -164,7 +164,7 @@ func (p *pager[T]) Iter() <-chan T {
|
|
|
defer close(p.done)
|
|
|
defer close(ch)
|
|
|
for page := range p.iteratePages() {
|
|
|
- if p.pctx.Err() != nil {
|
|
|
+ if p.ctx.Err() != nil {
|
|
|
p.pagePool <- page
|
|
|
break
|
|
|
}
|