-
Notifications
You must be signed in to change notification settings - Fork 36
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
test: extend R2DBC EventSourcedEndToEndSpec #1292
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
looking good
Thread.sleep(500) | ||
// resume projections again | ||
if (n == (numberOfEvents / 2) + 20) | ||
startProjectionsFactory() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I changed to var projections
recently. This would be projections = startProjectionsFactory()
.
The reason is that later we are stopping the projections, but that is not these new projections.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ah, missed that when aligning with the dynamodb test. I'll fix both.
startParams, | ||
(projectionId, sourceProvider) => | ||
R2dbcProjection | ||
.atLeastOnce( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
we also have some async variants, worth adding all?
atLeastOnceAsync
groupedWithinAsync
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Wasn't sure, but may as well cover all the variants now.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Extend the r2dbc EventSourcedEndToEndSpec to other projection types, following #1282 for DynamoDB.