HiPipe
0.7.0
C++17 data pipeline with Python bindings.
hipipe
core
stream
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
Generated by
1.8.16