-
Notifications
You must be signed in to change notification settings - Fork 88
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
feat: read enableChangesStream when sync changes stream #250
Conversation
3070055
to
a72920f
Compare
a72920f
to
fa1ab05
Compare
Codecov Report
@@ Coverage Diff @@
## main #250 +/- ##
=======================================
Coverage 97.16% 97.16%
=======================================
Files 119 119
Lines 3632 3633 +1
Branches 320 321 +1
=======================================
+ Hits 3529 3530 +1
Misses 103 103
Continue to review full report at Codecov.
|
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.
+1
|
@@ -62,7 +62,8 @@ export class ChangesStreamService extends AbstractService { | |||
this.logger.warn('[ChangesStreamService.executeTask:firstSeq] GET %s status: %s, data: %j, since: %s', | |||
changesStreamRegistry, status, data, since); | |||
} | |||
while (since) { | |||
// allow disable changesStream dynamic | |||
while (since && this.config.cnpmcore.enableChangesStream) { |
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.
配置了 enableChangesStream 为 false 的,都不会调用 executeTask
No description provided.