diff options
| author | Antoine A <> | 2024-02-08 09:44:43 +0100 |
|---|---|---|
| committer | Antoine A <> | 2024-02-08 09:44:43 +0100 |
| commit | 9b9ae5d3efc3ba8099734b4392ccf1d8b3bda422 (patch) | |
| tree | 134beb38e8c528854f1a1f23db2d7b2ff7311e47 | |
| parent | 4ddcada57dc252c4ccdb79d573228e25bc2811ed (diff) | |
| download | libeufin-9b9ae5d3efc3ba8099734b4392ccf1d8b3bda422.tar.gz libeufin-9b9ae5d3efc3ba8099734b4392ccf1d8b3bda422.tar.bz2 libeufin-9b9ae5d3efc3ba8099734b4392ccf1d8b3bda422.zip | |
Remove redundant query when poll timeout
| -rw-r--r-- | bank/src/main/kotlin/tech/libeufin/bank/db/Database.kt | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/bank/src/main/kotlin/tech/libeufin/bank/db/Database.kt b/bank/src/main/kotlin/tech/libeufin/bank/db/Database.kt index 3d9682ca..91262ce5 100644 --- a/bank/src/main/kotlin/tech/libeufin/bank/db/Database.kt +++ b/bank/src/main/kotlin/tech/libeufin/bank/db/Database.kt @@ -183,8 +183,11 @@ class Database(dbConfig: String, internal val bankCurrency: String, internal val val init = load() // Long polling if we found no transactions if (init.isEmpty()) { - polling.join() - load() + if (polling.join() != null) { + load() + } else { + init + } } else { polling.cancel() init |