Skip to content
This repository was archived by the owner on Dec 21, 2021. It is now read-only.

Commit f3f986a

Browse files
committed
Add client.options.maxGapRequests = 5 to client config, use to configure OrderMessages.
1 parent 421d3ee commit f3f986a

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

src/Config.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ export default function ClientConfig(opts: StreamrClientOptions = {}) {
2727
orderMessages: true,
2828
retryResendAfter: 5000,
2929
gapFillTimeout: 5000,
30+
maxGapRequests: 5,
3031
maxPublishQueueSize: 10000,
3132

3233
// Encryption options

src/subscribe/OrderMessages.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ let ID = 0
1616
*/
1717

1818
export default function OrderMessages(client, options = {}) {
19-
const { gapFillTimeout, retryResendAfter } = client.options
19+
const { gapFillTimeout, retryResendAfter, maxGapRequests } = client.options
2020
const { streamId, streamPartition, gapFill = true } = validateOptions(options)
2121
const debug = client.debug.extend(`OrderMessages::${ID}`)
2222
ID += 1
@@ -59,7 +59,7 @@ export default function OrderMessages(client, options = {}) {
5959
resendStreams.delete(resendMessageStream)
6060
await resendMessageStream.cancel()
6161
}
62-
}, gapFillTimeout, retryResendAfter, gapFill ? 5 : 0)
62+
}, gapFillTimeout, retryResendAfter, gapFill ? maxGapRequests : 0)
6363

6464
const markMessageExplicitly = orderingUtil.markMessageExplicitly.bind(orderingUtil)
6565

0 commit comments

Comments
 (0)