| 229 | } |
| 230 | |
| 231 | void RedisConnection::EnqueueCallback(const std::function<void(boost::asio::yield_context&)>& callback) |
| 232 | { |
| 233 | asio::post(m_Strand, [this, callback, ctime = Utility::GetTime()]() { |
| 234 | m_Queues.Push(WriteQueueItem{callback, ctime, {}}, false); |
| 235 | m_QueuedWrites.Set(); |
| 236 | }); |
| 237 | } |
| 238 | |
| 239 | /** |
| 240 | * Puts a no-op command with a result at the end of the queue and wait for the result, |
no test coverage detected