Using time out in cluster state observer as we are reusing the observ…

…er (#215) (#217)

Signed-off-by: Gaurav Bafna <[email protected]>

src/main/kotlin/com/amazon/elasticsearch/replication/util/Coroutines.kt

@@ -129,7 +129,7 @@ suspend fun ClusterStateObserver.waitForNextChange(reason: String, predicate: (C
             override fun onTimeout(timeout: TimeValue?) {
                 cont.resumeWithException(ElasticsearchTimeoutException("timed out waiting for $reason"))
             }
-        }, predicate)
+        }, predicate,  TimeValue(60000))
     }
 }