void Producer_sendAsync()

in src/producer.cc [32:39]


void Producer_sendAsync(Producer& producer, const Message& msg, SendCallback callback) {
    Py_BEGIN_ALLOW_THREADS producer.sendAsync(msg, callback);
    Py_END_ALLOW_THREADS

        if (PyErr_CheckSignals() == -1) {
        PyErr_SetInterrupt();
    }
}