ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-01-18 10:46:38 +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)

Browse Source
This commit is contained in:
Patrick Kuo 2018-06-08 16:30:37 +01:00 committed by josecoll
parent 68e1d281bc
commit 2fce979fe7
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

@ -93,7 +93,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() }
}