39template <std::ranges::range urng_t>
43 static_assert(std::ranges::input_range<urng_t>,
44 "The range parameter to async_input_buffer_view must be at least a std::ranges::input_range.");
45 static_assert(std::ranges::view<urng_t>,
46 "The range parameter to async_input_buffer_view must model std::ranges::view.");
47 static_assert(std::movable<std::ranges::range_value_t<urng_t>>,
48 "The range parameter to async_input_buffer_view must have a value_type that is std::movable.");
49 static_assert(std::constructible_from<std::ranges::range_value_t<urng_t>,
51 "The range parameter to async_input_buffer_view must have a value_type that is constructible by a moved "
52 "value of its reference type.");
64 contrib::fixed_buffer_queue<std::ranges::range_value_t<urng_t>>
buffer;
90 auto deleter = [] (
state * p)
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> &&
153 std::default_sentinel_t
end()
155 return std::default_sentinel;
159 std::default_sentinel_t
end()
const =
delete;
164template <std::ranges::range urng_t>
171 contrib::fixed_buffer_queue<std::ranges::range_value_t<urng_t>> * buffer_ptr =
nullptr;
212 iterator(contrib::fixed_buffer_queue<
std::ranges::range_value_t<urng_t>> & buffer) noexcept : buffer_ptr{&buffer}
243 assert(buffer_ptr !=
nullptr);
245 if (buffer_ptr->wait_pop(cached_value) == contrib::queue_op_status::closed)
270 return rhs == std::default_sentinel_t{};
276 return !(lhs == std::default_sentinel_t{});
282 return rhs != std::default_sentinel_t{};
293template <std::ranges::viewable_range urng_t>
315 template <std::ranges::range urng_t>
316 constexpr auto operator()(urng_t && urange,
size_t const buffer_size)
const
318 static_assert(std::ranges::input_range<urng_t>,
319 "The range parameter to views::async_input_buffer must be at least a std::ranges::input_range.");
320 static_assert(std::ranges::viewable_range<urng_t>,
321 "The range parameter to views::async_input_buffer cannot be a temporary of a non-view range.");
322 static_assert(std::movable<std::ranges::range_value_t<urng_t>>,
323 "The range parameter to views::async_input_buffer must have a value_type that is std::movable.");
324 static_assert(std::constructible_from<std::ranges::range_value_t<urng_t>,
326 "The range parameter to views::async_input_buffer must have a value_type that is constructible by a moved "
327 "value of its reference type.");
329 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:57
typename iter_pointer< it_t >::type iter_pointer_t
Return the pointer type of the input type (transformation_trait shortcut).
Definition: iterator_traits.hpp:176
constexpr auto async_input_buffer
A view adapter that returns a concurrent-queue-like view over the underlying range.
Definition: async_input_buffer.hpp:479
The internal SeqAn3 namespace.
Definition: aligned_sequence_concept.hpp:29
The SeqAn namespace for views.
Definition: char_strictly_to.hpp:22
SeqAn specific customisations in the standard namespace.
The <ranges> header from C++20's standard library.