| 35 | } |
| 36 | |
| 37 | InputStream::InputStream(int stream_id, StreamConfig &stream_config, |
| 38 | int node_id, |
| 39 | std::function<void(int, bool)> &throttled_cb, |
| 40 | size_t max_queue_size) |
| 41 | : stream_id_(stream_id), identifier_(stream_config.get_identifier()), |
| 42 | alias_(stream_config.get_alias()), notify_(stream_config.get_notify()), |
| 43 | node_id_(node_id), throttled_cb_(throttled_cb), |
| 44 | max_queue_size_(max_queue_size), |
| 45 | queue_(std::make_shared<SafeQueue<Packet>>()) { |
| 46 | queue_->set_identifier(identifier_); |
| 47 | } |
| 48 | |
| 49 | // InputStream::InputStream(const InputStream &input_stream) { |
| 50 | // stream_id_ = input_stream.stream_id_; |
nothing calls this directly
no test coverage detected