in tattler.go [214:228]
func (r *Runner) Start(ctx context.Context) error {
r.mu.Lock()
defer r.mu.Unlock()
for _, reader := range r.readers {
if err := reader.Run(ctx); err != nil {
return fmt.Errorf("reader(%T): %w", reader, err)
}
}
if err := r.router.Start(ctx); err != nil {
return err
}
return nil
}