ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-01-24 13:28:07 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

CORDA-1604 Node Info file watcher should block and load node info when node startup (#959) (#3333) (#3879)

Browse Source 
(cherry picked from commit 2fce979)

(cherry picked from commit 072b4207e0)
This commit is contained in:
Patrick Kuo 2018-09-06 10:13:22 +01:00 committed by josecoll
parent 6d43a654ff
commit 205d3c3797
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
node/src/main/kotlin/net/corda/node/services/network/NodeInfoWatcher.kt
View File

@ -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. * @return an [Observable] returning [NodeInfo]s, at most one [NodeInfo] is returned for each processed file.
*/ */
fun nodeInfoUpdates(): Observable<NodeInfo> { fun nodeInfoUpdates(): Observable<NodeInfo> {
return Observable.interval(pollInterval.toMillis(), TimeUnit.MILLISECONDS, scheduler) return Observable.interval(0, pollInterval.toMillis(), TimeUnit.MILLISECONDS, scheduler)
.flatMapIterable { loadFromDirectory() } .flatMapIterable { loadFromDirectory() }
} }