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

More refactoring.

Browse Source
This commit is contained in:
Marcelo Zimbres
2021-10-16 10:40:10 +02:00
parent f63bd40da3
commit f9acd015d2
9 changed files with 134 additions and 166 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
examples/async_basic.cpp
View File

@@ -12,40 +12,34 @@
using namespace aedis;
using tcp_socket = net::use_awaitable_t<>::as_default_on_t<net::ip::tcp::socket>;
using tcp_resolver = net::use_awaitable_t<>::as_default_on_t<net::ip::tcp::resolver>;
void print_event(std::pair<command, std::string> const& p)
net::awaitable<void> example()
{
std::cout << "Event: " << p.first << ".";
auto ex = co_await net::this_coro::executor;
tcp_resolver resolver{ex};
auto const res = co_await resolver.async_resolve("127.0.0.1", "6379");
tcp_socket socket{ex};
co_await net::async_connect(socket, res);
if (!std::empty(p.second))
std::cout << " Key: " << p.second << ".";
std::cout << std::endl;
}
net::awaitable<void>
example(
tcp_socket& socket,
std::queue<resp3::request>& requests)
{
std::queue<resp3::request> requests;
requests.push({});
requests.back().hello("3");
requests.back().hello();
resp3::response resp;
resp3::consumer cs;
for (;;) {
resp.clear();
resp3::response resp;
co_await cs.async_consume(socket, requests, resp);
std::cout << resp << std::endl;
if (resp.get_type() == resp3::type::push)
continue;
auto const id = requests.front().ids.front();
auto const& elem = requests.front().elements.front();
print_event(id);
switch (id.first) {
std::cout << elem << std::endl;
switch (elem.cmd) {
case command::hello:
{
prepare_next(requests);
@@ -68,13 +62,6 @@ example(
int main()
{
net::io_context ioc;
net::ip::tcp::resolver resolver{ioc};
auto const res = resolver.resolve("127.0.0.1", "6379");
tcp_socket socket{ioc};
net::connect(socket, res);
std::queue<resp3::request> requests;
co_spawn(ioc, example(socket, requests), net::detached);
co_spawn(ioc, example(), net::detached);
ioc.run();
}