()
| 595 | } |
| 596 | |
| 597 | func (e *sqliteEvents) All() iter.Seq[*session.Event] { |
| 598 | return func(yield func(*session.Event) bool) { |
| 599 | events, err := e.service.GetEvents(context.Background(), e.sessionID, nil) |
| 600 | if err != nil { |
| 601 | return |
| 602 | } |
| 603 | |
| 604 | for i := range events { |
| 605 | if !yield(&events[i]) { |
| 606 | return |
| 607 | } |
| 608 | } |
| 609 | } |
| 610 | } |
| 611 | |
| 612 | func (e *sqliteEvents) Len() int { |
| 613 | e.service.mu.RLock() |