Method close

cpp/examples/multithreaded_client_flow_control.cpp:191–200

Thread safe

    // Thread safe
    void close() {
        std::lock_guard<std::mutex> l(lock_);
        if (!closed_) {
            closed_ = true;
            can_receive_.notify_all();
            if (work_queue_) {
                work_queue_->add([this]() { this->receiver_.connection().close(); });
            }
        }
    }

  private:
    // ==== The following are called by proton threads only.