diff options
Diffstat (limited to 'entities/identity/identity.go')
| -rw-r--r-- | entities/identity/identity.go | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/entities/identity/identity.go b/entities/identity/identity.go index 22ce652c..e654cb2b 100644 --- a/entities/identity/identity.go +++ b/entities/identity/identity.go @@ -238,6 +238,9 @@ func readAll(repo repository.ClockedRepo, refPrefix string) <-chan entity.Stream return } + total := int64(len(refs)) + current := int64(1) + for _, ref := range refs { i, err := read(repo, ref) @@ -246,7 +249,12 @@ func readAll(repo repository.ClockedRepo, refPrefix string) <-chan entity.Stream return } - out <- entity.StreamedEntity[*Identity]{Entity: i} + out <- entity.StreamedEntity[*Identity]{ + Entity: i, + CurrentEntity: current, + TotalEntities: total, + } + current++ } }() |