812
startEventID int64,
813
endEventID int64,
815
>
var token []byte
816
>
var events []*historypb.HistoryEvent
817
>
for doContinue := true; doContinue; doContinue = len(token) > 0 {
818
>
resp, err := s.store.ReadHistoryBranch(s.Ctx, &p.ReadHistoryBranchRequest{
819
>
ShardID: shardID,
820
>
BranchToken: branchToken,
821
>
MinEventID: startEventID,
822
>
MaxEventID: endEventID,
823
>
PageSize: 1, // use 1 here for better testing exp
824
>
NextPageToken: token,
825
>
})
826
>
s.NoError(err)
827
>
token = resp.NextPageToken
828
>
events = append(events, resp.HistoryEvents...)
829
>
}
830
>
return events
831
}
832