mirror of https://github.com/oxen-io/oxen-mq.git
716d73d196
We really don't *ever* want send to block, no matter how it is called, since the send is always in the proxy thread. This makes the actual send call always non-blocking, and adds callbacks that we can invoke on send failures: either on queue full errors (which might be recoverable), or both full queue and hard failures (which are generally not recoverable). These callbacks are both optional: they have to be passed in using `send_option::queue_full` (if you just want queue full notifies) or `send_option::queue_failure` (if you want queue full notifies *and* other send exceptions). |
||
---|---|---|
.. | ||
Catch2@b3b07215d1 | ||
CMakeLists.txt | ||
common.h | ||
main.cpp | ||
test_batch.cpp | ||
test_commands.cpp | ||
test_connect.cpp | ||
test_requests.cpp | ||
test_string_view.cpp |