Skip to content

Commit 02c4fa4

Browse files
brustolinAGiorgetti
authored andcommitted
fix: GetStreamsToSnapshot crashing for results with more than 512 items (#55)
1 parent 2b62312 commit 02c4fa4

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

‎src/NEventStore.Persistence.Sql/SqlPersistenceEngine.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -212,7 +212,7 @@ public virtual IEnumerable<IStreamHead> GetStreamsToSnapshot(string bucketId, in
212212
query.AddParameter(_dialect.Threshold, maxThreshold);
213213
return
214214
query.ExecutePagedQuery(statement,
215-
(q, s) => q.SetParameter(_dialect.StreamId, _dialect.CoalesceParameterValue(s.StreamId()), DbType.AnsiString)) // todo: I'm not sure this is used, the query does not have a "StreamId" parameter
215+
(q, s) => { }) // No next page delegate needed - @Skip parameter is handled automatically by PagedEnumerationCollection
216216
.Select(x => x.GetStreamToSnapshot());
217217
});
218218
}
@@ -656,4 +656,4 @@ public string GetHash(string streamId)
656656
}
657657
}
658658
}
659-
}
659+
}

0 commit comments

Comments
 (0)