void waitForAsyncResult()

in src/utils.cc [22:35]

• 8 lines of code
• 1 McCabe index (conditional complexity)

void waitForAsyncResult(std::function<void(ResultCallback)> func) {
    auto promise = std::make_shared<std::promise<Result>>();

    {
        // Always call the Pulsar C++ client methods without holding
        // the GIL. This avoids deadlocks due the sequence of acquiring
        // mutexes by different threads. eg:
        // Thread-1: GIL -> producer.lock
        // Thread-2: producer.lock -> GIL (In a callback)
        py::gil_scoped_release release;
        func([promise](Result result) { promise->set_value(result); });
    }
    internal::waitForResult(*promise);
}