| 77 | }; |
| 78 | |
| 79 | void PacketPipelineComponents::initialize(RgbPacketProcessor *rgb, DepthPacketProcessor *depth) |
| 80 | { |
| 81 | rgb_parser_ = new RgbPacketStreamParser(); |
| 82 | depth_parser_ = new DepthPacketStreamParser(); |
| 83 | |
| 84 | rgb_processor_ = rgb; |
| 85 | depth_processor_ = depth; |
| 86 | |
| 87 | async_rgb_processor_ = new AsyncPacketProcessor<RgbPacket>(rgb_processor_); |
| 88 | async_depth_processor_ = new AsyncPacketProcessor<DepthPacket>(depth_processor_); |
| 89 | |
| 90 | rgb_parser_->setPacketProcessor(async_rgb_processor_); |
| 91 | depth_parser_->setPacketProcessor(async_depth_processor_); |
| 92 | } |
| 93 | |
| 94 | PacketPipelineComponents::~PacketPipelineComponents() |
| 95 | { |
no test coverage detected