boost/redis
2
0
Fork 0
mirror of https://github.com/boostorg/redis.git synced 2026-01-19 04:42:09 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #258 from boostorg/refactoring_clean_code

Browse Source 
Refactors reader_op to simplify sans-io.
This commit is contained in:
Marcelo
2025-05-29 14:52:04 +02:00
committed by GitHub
parent b58e4f94de 35d50700b9
commit 479068e778
4 changed files with 64 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
test/test_low_level_sync_sans_io.cpp
View File

@@ -261,7 +261,7 @@ BOOST_AUTO_TEST_CASE(multiplexer_push)
mpx.get_read_buffer() = ">2\r\n+one\r\n+two\r\n";
boost::system::error_code ec;
auto const ret = mpx.commit_read(ec);
auto const ret = mpx.consume_next(ec);
BOOST_TEST(ret.first.value());
BOOST_CHECK_EQUAL(ret.second, 16u);
@@ -286,12 +286,12 @@ BOOST_AUTO_TEST_CASE(multiplexer_push_needs_more)
mpx.get_read_buffer() = ">2\r\n+one\r";
boost::system::error_code ec;
auto ret = mpx.commit_read(ec);
auto ret = mpx.consume_next(ec);
BOOST_TEST(!ret.first.has_value());
mpx.get_read_buffer().append("\n+two\r\n");
ret = mpx.commit_read(ec);
ret = mpx.consume_next(ec);
BOOST_TEST(ret.first.value());
BOOST_CHECK_EQUAL(ret.second, 16u);
@@ -381,9 +381,9 @@ BOOST_AUTO_TEST_CASE(multiplexer_pipeline)
// Simulates a socket read by putting some data in the read buffer.
mpx.get_read_buffer().append("+one\r\n");
// Informs the multiplexer the read operation is concluded.
// Consumes the next message in the read buffer.
boost::system::error_code ec;
auto const ret = mpx.commit_read(ec);
auto const ret = mpx.consume_next(ec);
// The read operation should have been successfull.
BOOST_TEST(ret.first.has_value());