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

This commit is contained in:
Patrick Kuo 2018-06-08 16:30:37 +01:00 committed by josecoll
parent 68e1d281bc
commit 2fce979fe7

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. * @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() }
} }