12345678910111213141516171819202122232425262728293031323334 |
- #pragma once
- #include "consumer.h"
- #include "event.h"
- #include "writer.h"
- namespace NYsonPull {
-
-
-
-
-
- template <typename Producer, typename Consumer>
- inline void Bridge(Producer&& producer, Consumer&& consumer) {
- for (;;) {
- auto& event = producer.NextEvent();
- consumer.OnEvent(event);
- if (event.Type() == EEventType::EndStream) {
- break;
- }
- }
- }
- template <typename Producer>
- inline void Bridge(Producer&& producer, TWriter& writer_) {
- Bridge(std::forward<Producer>(producer), writer_.GetConsumer());
- }
- template <typename Producer>
- inline void Bridge(Producer&& producer, TWriter&& writer_) {
- Bridge(std::forward<Producer>(producer), writer_.GetConsumer());
- }
- }
|