ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-05-31 22:50:53 +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)

Browse Source 
(cherry picked from commit 2fce979)
This commit is contained in:
Patrick Kuo 2018-06-08 18:39:46 +01:00 committed by josecoll
parent 003684b7fb
commit 072b4207e0
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

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