From 151e945d9f789f49e81b9a80ae4635cc68bfc6ea Mon Sep 17 00:00:00 2001 From: Ernest Zaslavsky Date: Thu, 19 Mar 2026 13:49:40 +0200 Subject: [PATCH] Fix formatting after previous patch --- test/lib/limiting_data_source.cc | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/test/lib/limiting_data_source.cc b/test/lib/limiting_data_source.cc index 3213c8e90d..6925109192 100644 --- a/test/lib/limiting_data_source.cc +++ b/test/lib/limiting_data_source.cc @@ -17,21 +17,20 @@ future> limiting_data_source_impl::do_get() { return make_ready_future>(std::move(res)); } -limiting_data_source_impl::limiting_data_source_impl(data_source&& src, size_t limit) - : _src(std::move(src)) - , _limit(limit) -{} +limiting_data_source_impl::limiting_data_source_impl(data_source&& src, size_t limit) : _src(std::move(src)), _limit(limit) { +} future> limiting_data_source_impl::get() { if (_buf.empty()) { _buf.release(); - return _src.get().then([this] (auto&& buf) { + return _src.get().then([this](auto&& buf) { _buf = std::move(buf); return do_get(); }); } return do_get(); } + future> limiting_data_source_impl::skip(uint64_t n) { if (n < _buf.size()) { _buf.trim_front(n); @@ -39,7 +38,7 @@ future> limiting_data_source_impl::skip(uint64_t n) { } n -= _buf.size(); _buf.release(); - return _src.skip(n).then([this] (auto&& buf) { + return _src.skip(n).then([this](auto&& buf) { _buf = std::move(buf); return do_get(); });