From 205d3c37976dc3e9d641b8c9f802532be739ea65 Mon Sep 17 00:00:00 2001 From: Patrick Kuo Date: Thu, 6 Sep 2018 10:13:22 +0100 Subject: [PATCH] CORDA-1604 Node Info file watcher should block and load node info when node startup (#959) (#3333) (#3879) (cherry picked from commit 2fce979) (cherry picked from commit 072b4207e0877acc814d89805a6c17b1a22df56d) --- .../kotlin/net/corda/node/services/network/NodeInfoWatcher.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/node/src/main/kotlin/net/corda/node/services/network/NodeInfoWatcher.kt b/node/src/main/kotlin/net/corda/node/services/network/NodeInfoWatcher.kt index bbcbb37e89..a24c34de25 100644 --- a/node/src/main/kotlin/net/corda/node/services/network/NodeInfoWatcher.kt +++ b/node/src/main/kotlin/net/corda/node/services/network/NodeInfoWatcher.kt @@ -78,7 +78,7 @@ class NodeInfoWatcher(private val nodePath: Path, * @return an [Observable] returning [NodeInfo]s, at most one [NodeInfo] is returned for each processed file. */ fun nodeInfoUpdates(): Observable { - return Observable.interval(pollInterval.toMillis(), TimeUnit.MILLISECONDS, scheduler) + return Observable.interval(0, pollInterval.toMillis(), TimeUnit.MILLISECONDS, scheduler) .flatMapIterable { loadFromDirectory() } }