DLDatabase
| 492 | |
| 493 | // DLDatabase |
| 494 | DLDatabase::DLDatabase(Reference<FdbCApi> api, ThreadFuture<FdbCApi::FDBDatabase*> dbFuture) : api(api), db(nullptr) { |
| 495 | addref(); |
| 496 | ready = mapThreadFuture<FdbCApi::FDBDatabase*, Void>(dbFuture, [this](ErrorOr<FdbCApi::FDBDatabase*> db) { |
| 497 | if (db.isError()) { |
| 498 | delref(); |
| 499 | return ErrorOr<Void>(db.getError()); |
| 500 | } |
| 501 | |
| 502 | this->db = db.get(); |
| 503 | delref(); |
| 504 | return ErrorOr<Void>(Void()); |
| 505 | }); |
| 506 | } |
| 507 | |
| 508 | ThreadFuture<Void> DLDatabase::onReady() { |
| 509 | return ready; |