From b12330abfd8ff9207a332e8a47e05703c26697f5 Mon Sep 17 00:00:00 2001
From: Cosmin-Catalin Crisan <cosmin.crisan@cloverheap.com>
Date: Fri, 10 Dec 2021 20:20:11 +0200
Subject: [PATCH] grpc-js: Send backoffOptions to BackoffTimeout

---
 packages/grpc-js/src/resolving-load-balancer.ts | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/packages/grpc-js/src/resolving-load-balancer.ts b/packages/grpc-js/src/resolving-load-balancer.ts
index 235748f7..5bc86128 100644
--- a/packages/grpc-js/src/resolving-load-balancer.ts
+++ b/packages/grpc-js/src/resolving-load-balancer.ts
@@ -26,7 +26,7 @@ import { ConnectivityState } from './connectivity-state';
 import { ConfigSelector, createResolver, Resolver } from './resolver';
 import { ServiceError } from './call';
 import { Picker, UnavailablePicker, QueuePicker } from './picker';
-import { BackoffTimeout } from './backoff-timeout';
+import { BackoffOptions, BackoffTimeout } from './backoff-timeout';
 import { Status } from './constants';
 import { StatusObject } from './call-stream';
 import { Metadata } from './metadata';
@@ -248,7 +248,10 @@ export class ResolvingLoadBalancer implements LoadBalancer {
       },
       channelOptions
     );
-
+    const backoffOptions: BackoffOptions = {
+      initialDelay: channelOptions['grpc.initial_reconnect_backoff_ms'],
+      maxDelay: channelOptions['grpc.max_reconnect_backoff_ms'],
+    };
     this.backoffTimeout = new BackoffTimeout(() => {
       if (this.continueResolving) {
         this.updateResolution();
@@ -256,7 +259,7 @@ export class ResolvingLoadBalancer implements LoadBalancer {
       } else {
         this.updateState(this.latestChildState, this.latestChildPicker);
       }
-    });
+    }, backoffOptions);
     this.backoffTimeout.unref();
   }