boost/redis
2
0
Fork 0
mirror of https://github.com/boostorg/redis.git synced 2026-02-09 11:22:22 +00:00
Code Issues Projects Releases Wiki Activity

Adds the key name to the request queue.

Browse Source
This commit is contained in:
Marcelo Zimbres
2021-09-26 19:15:17 +02:00
parent a846638e18
commit 2ab6f2bd1d
8 changed files with 88 additions and 72 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
examples/async_basic.cpp
View File

@@ -9,6 +9,16 @@
using namespace aedis;
void print_event(resp3::type t, std::pair<command, std::string> const& p)
{
std::cout << "Event: " << p.first << ".";
if (!std::empty(p.second))
std::cout << " Key: " << p.second << ".";
std::cout << " Type: " << t << std::endl;
}
net::awaitable<void>
example(net::ip::tcp::socket& socket,
std::queue<resp3::request>& requests)
@@ -20,17 +30,17 @@ example(net::ip::tcp::socket& socket,
resp3::consumer cs;
for (;;) {
auto const type = co_await cs.async_consume(socket, requests, resp, net::use_awaitable);
auto const t = co_await cs.async_consume(socket, requests, resp, net::use_awaitable);
if (type == resp3::type::flat_push) {
std::cout << "Event: " << "(" << type << ")" << std::endl;
if (t == resp3::type::flat_push) {
std::cout << "Event: " << "(" << t << ")" << std::endl;
continue;
}
auto const cmd = requests.front().commands.front();
auto const id = requests.front().ids.front();
std::cout << "Event: " << cmd << " (" << type << ")" << std::endl;
switch (cmd) {
print_event(t, id);
switch (id.first) {
case command::hello:
{
prepare_next(requests);