nds_data_iterator.hh

//
// Created by jonathan.hanks on 5/25/18.
//
 
#ifndef NDS2_CLIENT_NDS_DATA_ITERATOR_HH
#define NDS2_CLIENT_NDS_DATA_ITERATOR_HH
 
#include <iterator>
#include <memory>
 
#include "nds_buffer.hh"
#include "nds_channel.hh"
 
namespace NDS
{
    namespace detail
    {
        class iterate_handler;
    }
 
    inline namespace abi_0
    {
        struct request_period
        {
            using gps_second_type = NDS::buffer::gps_second_type;
            typedef long    stride_type;
            gps_second_type start;
            gps_second_type stop;
            stride_type     stride;
 
            const static stride_type FAST_STRIDE = -1;
 
            const static stride_type AUTO_STRIDE = 0;
 
            request_period( ) : start( 0 ), stop( 0 ), stride( 0 )
            {
            }
 
            explicit request_period( stride_type requested_stride )
                : start( 0 ), stop( 0 ), stride( requested_stride )
            {
            }
 
            explicit request_period( gps_second_type requested_start,
                                     gps_second_type requested_stop )
                : start( requested_start ), stop( requested_stop ), stride( 0 )
            {
            }
 
            explicit request_period( gps_second_type requested_start,
                                     gps_second_type requested_stop,
                                     stride_type     requested_stride )
                : start( requested_start ), stop( requested_stop ),
                  stride( requested_stride )
            {
            }
        };
 
        class data_stream_iterator
        {
        public:
            typedef std::shared_ptr< buffers_type > value_type;
            typedef value_type&                     reference;
            typedef value_type*                     pointer;
            typedef std::size_t                     difference_type;
            typedef std::input_iterator_tag         iterator_category;
 
            DLL_EXPORT data_stream_iterator( );
            DLL_EXPORT
            data_stream_iterator( const data_stream_iterator& other );
            DLL_EXPORT
            data_stream_iterator( data_stream_iterator&& other ) noexcept;
 
            DLL_EXPORT
            data_stream_iterator( std::shared_ptr< detail::iterate_handler > p,
                                  value_type c );
 
            DLL_EXPORT ~data_stream_iterator( );
 
            DLL_EXPORT data_stream_iterator&
            operator=( const data_stream_iterator& other );
            DLL_EXPORT data_stream_iterator&
            operator=( data_stream_iterator&& other ) noexcept;
 
            DLL_EXPORT bool
            operator==( const data_stream_iterator& other ) const;
 
            DLL_EXPORT bool
            operator!=( const data_stream_iterator& other ) const;
 
            DLL_EXPORT reference operator*( );
 
            DLL_EXPORT data_stream_iterator& operator++( );
            DLL_EXPORT data_stream_iterator operator++( int );
 
        private:
            std::shared_ptr< detail::iterate_handler > p_;
            value_type                                 cache_;
        };
 
        class data_iterable
        {
        public:
            typedef data_stream_iterator iterator_type;
 
            DLL_EXPORT explicit data_iterable(
                std::shared_ptr< NDS::detail::iterate_handler > handler );
            DLL_EXPORT data_iterable( const data_iterable& other );
            DLL_EXPORT data_iterable( data_iterable&& other ) noexcept;
 
            DLL_EXPORT ~data_iterable( );
 
            DLL_EXPORT data_iterable& operator=( const data_iterable& other );
            DLL_EXPORT data_iterable&
            operator=( data_iterable&& other ) noexcept;
 
            DLL_EXPORT iterator_type begin( );
 
            DLL_EXPORT iterator_type end( );
 
            DLL_EXPORT void abort( );
 
        private:
            std::shared_ptr< NDS::detail::iterate_handler > p_;
        };
    }
}
 
#endif // NDS2_CLIENT_NDS_DATA_ITERATOR_HH