add_begin_callback(std::function< void(GenericInputStream const &)> const &callback) | GenericInputStream< T, D > | inline |
add_end_callback(std::function< void(GenericInputStream const &)> const &callback) | GenericInputStream< T, D > | inline |
add_filter(std::function< bool(T const &)> const &filter) | GenericInputStream< T, D > | inline |
add_on_enter_observer(std::function< void(T const &)> const &observer) | GenericInputStream< T, D > | inline |
add_on_leave_observer(std::function< void(T const &)> const &observer) | GenericInputStream< T, D > | inline |
add_transform(std::function< void(T &)> const &transform) | GenericInputStream< T, D > | inline |
add_transform_filter(std::function< bool(T &)> const &filter) | GenericInputStream< T, D > | inline |
begin() | GenericInputStream< T, D > | inline |
block_size() const | GenericInputStream< T, D > | inline |
block_size(size_t value) | GenericInputStream< T, D > | inline |
clear_callbacks() | GenericInputStream< T, D > | inline |
clear_filters_and_transformations() | GenericInputStream< T, D > | inline |
clear_observers() | GenericInputStream< T, D > | inline |
Data typedef | GenericInputStream< T, D > | |
data() const | GenericInputStream< T, D > | inline |
data() | GenericInputStream< T, D > | inline |
DEFAULT_BLOCK_SIZE | GenericInputStream< T, D > | static |
difference_type typedef | GenericInputStream< T, D > | |
end() | GenericInputStream< T, D > | inline |
GenericInputStream()=default | GenericInputStream< T, D > | |
GenericInputStream(std::function< bool(value_type &)> get_element, std::shared_ptr< utils::ThreadPool > thread_pool=nullptr, size_t block_size=DEFAULT_BLOCK_SIZE) | GenericInputStream< T, D > | inline |
GenericInputStream(std::function< bool(value_type &)> get_element, Data const &data, std::shared_ptr< utils::ThreadPool > thread_pool=nullptr, size_t block_size=DEFAULT_BLOCK_SIZE) | GenericInputStream< T, D > | inline |
GenericInputStream(std::function< bool(value_type &)> get_element, Data &&data, std::shared_ptr< utils::ThreadPool > thread_pool=nullptr, size_t block_size=DEFAULT_BLOCK_SIZE) | GenericInputStream< T, D > | inline |
GenericInputStream(self_type const &)=default | GenericInputStream< T, D > | |
GenericInputStream(self_type &&)=default | GenericInputStream< T, D > | |
Iterator | GenericInputStream< T, D > | |
iterator_category typedef | GenericInputStream< T, D > | |
operator bool() const | GenericInputStream< T, D > | inline |
operator=(self_type const &)=default | GenericInputStream< T, D > | |
operator=(self_type &&)=default | GenericInputStream< T, D > | |
pointer typedef | GenericInputStream< T, D > | |
reference typedef | GenericInputStream< T, D > | |
self_type typedef | GenericInputStream< T, D > | |
thread_pool() const | GenericInputStream< T, D > | inline |
thread_pool(std::shared_ptr< utils::ThreadPool > value) | GenericInputStream< T, D > | inline |
value_type typedef | GenericInputStream< T, D > | |
~GenericInputStream()=default | GenericInputStream< T, D > | |