feat: add polling interval to polling transport

Signed-off-by: Timo Glastra <[email protected]>
openwallet-foundation · Jun 15, 2021 · f7200e9 · f7200e9
1 parent a648cad
commit f7200e9
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/docs/getting-started/1-transports.md b/docs/getting-started/1-transports.md
@@ -39,7 +39,8 @@ const agentConfig = {
 
 const agent = new Agent(agentConfig)
 
-const pollingInboundTransporter = new PollingInboundTransporter()
+// Construct polling inbound transporter with optional polling interval in ms
+const pollingInboundTransporter = new PollingInboundTransporter(5000)
 
 agent.setInboundTransporter(pollingInboundTransporter)
 ```

diff --git a/src/transport/PollingInboundTransporter.ts b/src/transport/PollingInboundTransporter.ts
@@ -7,9 +7,11 @@ import { sleep } from '../utils/sleep'
 
 export class PollingInboundTransporter implements InboundTransporter {
   public stop: boolean
+  private pollingInterval: number
 
-  public constructor() {
+  public constructor(pollingInterval = 5000) {
     this.stop = false
+    this.pollingInterval = pollingInterval
   }
 
   public async start(agent: Agent) {
@@ -41,7 +43,7 @@ export class PollingInboundTransporter implements InboundTransporter {
   private async pollDownloadMessages(agent: Agent) {
     while (!this.stop) {
       await agent.routing.downloadMessages()
-      await sleep(5000)
+      await sleep(this.pollingInterval)
     }
   }
 }