in src/reader.cc [28:36]
Message Reader_readNextTimeout(Reader& reader, int timeoutMs) {
Message msg;
Result res;
Py_BEGIN_ALLOW_THREADS res = reader.readNext(msg, timeoutMs);
Py_END_ALLOW_THREADS
CHECK_RESULT(res);
return msg;
}