37template <std::ranges::range urng_t>
41 static_assert(std::ranges::input_range<urng_t>,
42 "The range parameter to async_input_buffer_view must be at least a std::ranges::input_range.");
43 static_assert(std::ranges::view<urng_t>,
44 "The range parameter to async_input_buffer_view must model std::ranges::view.");
45 static_assert(std::movable<std::ranges::range_value_t<urng_t>>,
46 "The range parameter to async_input_buffer_view must have a value_type that is std::movable.");
48 std::constructible_from<std::ranges::range_value_t<urng_t>,
50 "The range parameter to async_input_buffer_view must have a value_type that is constructible by a moved "
51 "value of its reference type.");
63 contrib::fixed_buffer_queue<std::ranges::range_value_t<urng_t>>
buffer;
89 auto deleter = [](
state * p)
100 new state{std::move(_urng),
101 contrib::fixed_buffer_queue<std::ranges::range_value_t<urng_t>>{buffer_size},
108 if (
state.
buffer.wait_push(std::move(val)) == contrib::queue_op_status::closed)
118 template <
typename other_urng_t>
121 std::ranges::viewable_range<other_urng_t>
152 std::default_sentinel_t
end()
154 return std::default_sentinel;
158 std::default_sentinel_t
end()
const =
delete;
163template <std::ranges::range urng_t>
170 contrib::fixed_buffer_queue<std::ranges::range_value_t<urng_t>> * buffer_ptr =
nullptr;
210 iterator(contrib::fixed_buffer_queue<
std::ranges::range_value_t<urng_t>> & buffer) noexcept : buffer_ptr{&buffer}
241 assert(buffer_ptr !=
nullptr);
243 if (buffer_ptr->wait_pop(cached_value) == contrib::queue_op_status::closed)
268 return rhs == std::default_sentinel_t{};
274 return !(lhs == std::default_sentinel_t{});
280 return rhs != std::default_sentinel_t{};
291template <std::ranges::viewable_range urng_t>
313 template <std::ranges::range urng_t>
314 constexpr auto operator()(urng_t && urange,
size_t const buffer_size)
const
316 static_assert(std::ranges::input_range<urng_t>,
317 "The range parameter to views::async_input_buffer must be at least a std::ranges::input_range.");
318 static_assert(std::ranges::viewable_range<urng_t>,
319 "The range parameter to views::async_input_buffer cannot be a temporary of a non-view range.");
320 static_assert(std::movable<std::ranges::range_value_t<urng_t>>,
321 "The range parameter to views::async_input_buffer must have a value_type that is std::movable.");
323 std::constructible_from<std::ranges::range_value_t<urng_t>,
325 "The range parameter to views::async_input_buffer must have a value_type that is constructible by a moved "
326 "value of its reference type.");
328 if (buffer_size == 0)
Provides seqan3::detail::adaptor_from_functor.
Provides seqan3::buffer_queue.
Template for range adaptor closure objects that store arguments and wrap a proto-adaptor.
Definition adaptor_from_functor.hpp:54
typename iter_pointer< it_t >::type iter_pointer_t
Return the pointer type of the input type (transformation_trait shortcut).
Definition iterator_traits.hpp:151
constexpr auto async_input_buffer
A view adapter that returns a concurrent-queue-like view over the underlying range.
Definition async_input_buffer.hpp:478
The internal SeqAn3 namespace.
Definition aligned_sequence_concept.hpp:26
The SeqAn namespace for views.
Definition char_strictly_to.hpp:19
SeqAn specific customisations in the standard namespace.