Merge pull request #3 from github/feat-add-configurable-reconnectwindow

keithamus · web-flow · commit b34590261b31 · 2021-10-22T17:52:12.000+01:00
feat: add configurable reconnectWindow
diff --git a/src/stable-socket.ts b/src/stable-socket.ts
@@ -14,6 +14,7 @@ export interface Socket {
 }
 
 export interface SocketDelegate {
+  reconnectWindow?: number
   socketDidOpen(socket: Socket): void
   socketDidClose(socket: Socket, code?: number, reason?: string): void
   socketDidFinish(socket: Socket): void
@@ -55,7 +56,7 @@ export class StableSocket implements Socket {
       if (fatal) {
         this.delegate.socketDidFinish(this)
       } else {
-        setTimeout(() => this.open(), rand(100, 150))
+        setTimeout(() => this.open(), rand(100, 100 + (this.delegate.reconnectWindow || 50)))
       }
     }
     this.socket.onmessage = (event: MessageEvent) => {

Original file line number	Diff line number	Diff line change
`@@ -14,6 +14,7 @@ export interface Socket {`
`14`	`14`	`}`
`15`	`15`
`16`	`16`	`export interface SocketDelegate {`
	`17`	`+ reconnectWindow?: number`
`17`	`18`	`socketDidOpen(socket: Socket): void`
`18`	`19`	`socketDidClose(socket: Socket, code?: number, reason?: string): void`
`19`	`20`	`socketDidFinish(socket: Socket): void`
`@@ -55,7 +56,7 @@ export class StableSocket implements Socket {`
`55`	`56`	`if (fatal) {`
`56`	`57`	`this.delegate.socketDidFinish(this)`
`57`	`58`	`} else {`
`58`		`- setTimeout(() => this.open(), rand(100, 150))`
	`59`	`+ setTimeout(() => this.open(), rand(100, 100 + (this.delegate.reconnectWindow \|\| 50)))`
`59`	`60`	`}`
`60`	`61`	`}`
`61`	`62`	`this.socket.onmessage = (event: MessageEvent) => {`