HiPipe  0.7.0
C++17 data pipeline with Python bindings.
stream_t.hpp
1 /****************************************************************************
2  * hipipe library
3  * Copyright (c) 2018, Iterait a.s.
4  * Author(s) Filip Matzner
5  *
6  * This file is distributed under the MIT License.
7  * See the accompanying file LICENSE.txt for the complete license agreement.
8  ****************************************************************************/
9 
10 #pragma once
11 
12 #include <hipipe/core/stream/batch_t.hpp>
13 
14 #include <range/v3/view/any_view.hpp>
15 
16 namespace hipipe::stream {
17 
18 
24 using forward_stream_t = ranges::any_view<batch_t, ranges::category::forward>;
25 
26 
32 using input_stream_t = ranges::any_view<batch_t, ranges::category::input>;
33 
34 } // namespace hipipe::stream
hipipe::stream::input_stream_t
ranges::any_view< batch_t, ranges::category::input > input_stream_t
The stream type after special eager operations.
Definition: stream_t.hpp:37
hipipe::stream::forward_stream_t
ranges::any_view< batch_t, ranges::category::forward > forward_stream_t
The stream itself, i.e., a range of batches.
Definition: stream_t.hpp:29