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

Ports read functions to use the dynamic_buffer.

Browse Source
This commit is contained in:
Marcelo Zimbres
2022-01-09 16:26:38 +01:00
parent b3e541b4fe
commit 589181d4eb
16 changed files with 204 additions and 213 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
examples/response_queue.cpp
View File

@@ -1,5 +1,4 @@
/* Copyright (c) 2019 Marcelo Zimbres Silva (mzimbres at gmail dot com)
/// \example basic1.cpp
/* Copyright (c) 2019 Marcelo Zimbres Silva (mzimbres@gmail.com)
*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
@@ -10,15 +9,16 @@
#include <aedis/aedis.hpp>
#include "utils.ipp"
namespace resp3 = aedis::resp3;
using aedis::command;
using aedis::resp3::serializer;
using aedis::resp3::async_read;
using aedis::resp3::node;
using aedis::resp3::adapt;
using resp3::serializer;
using resp3::node;
using resp3::adapt;
namespace net = aedis::net;
using net::async_write;
using net::buffer;
using net::dynamic_buffer;
/// Processes the responses in a loop using the helper queue.
net::awaitable<void> ping()
@@ -40,13 +40,13 @@ net::awaitable<void> ping()
while (!std::empty(sr.commands)) {
switch (sr.commands.front()) {
case command::ping:
co_await async_read(socket, buffer, adapt(ping));
co_await resp3::async_read(socket, dynamic_buffer(buffer), adapt(ping));
break;
case command::quit:
co_await async_read(socket, buffer, adapt(quit));
co_await resp3::async_read(socket, dynamic_buffer(buffer), adapt(quit));
break;
default:
co_await async_read(socket, buffer);
co_await resp3::async_read(socket, dynamic_buffer(buffer));
}
sr.commands.pop();