1314
nextEventID int64,
1315
branchToken []byte,
1317
>
1318
>
return func(paginationToken []byte) ([]*historypb.History, []byte, error) {
1319
>
1320
>
resp, err := r.executionMgr.ReadHistoryBranchByBatch(ctx, &persistence.ReadHistoryBranchRequest{
1321
>
BranchToken: branchToken,
1322
>
MinEventID: firstEventID,
1323
>
MaxEventID: nextEventID,
1324
>
PageSize: defaultPageSize,
1325
>
NextPageToken: paginationToken,
1326
>
ShardID: r.shardContext.GetShardID(),
1327
>
})
1328
>
if err != nil {
1329
return nil, nil, err
1330
}
1332
}
1333
}