From 072b4207e0877acc814d89805a6c17b1a22df56d Mon Sep 17 00:00:00 2001
From: Patrick Kuo <patrick.kuo@r3.com>
Date: Fri, 8 Jun 2018 18:39:46 +0100
Subject: [PATCH] CORDA-1604 Node Info file watcher should block and load node
 info when node startup (#959) (#3333)

(cherry picked from commit 2fce979)
---
 .../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 4c08bc8ee7..dacf99bdf3 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
@@ -83,7 +83,7 @@ class NodeInfoWatcher(private val nodePath: Path,
      * @return an [Observable] returning [NodeInfoUpdate]s, at most one [NodeInfo] is returned for each processed file.
      */
     fun nodeInfoUpdates(): Observable<NodeInfoUpdate> {
-        return Observable.interval(pollInterval.toMillis(), TimeUnit.MILLISECONDS, scheduler)
+        return Observable.interval(0, pollInterval.toMillis(), TimeUnit.MILLISECONDS, scheduler)
                 .flatMapIterable { loadFromDirectory() }
     }