diff options
author | Mikhail Borisov <borisov.mikhail@gmail.com> | 2022-02-10 16:45:40 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:40 +0300 |
commit | 5d50718e66d9c037dc587a0211110b7d25a66185 (patch) | |
tree | e98df59de24d2ef7c77baed9f41e4875a2fef972 /library/cpp/yson_pull/range.h | |
parent | a6a92afe03e02795227d2641b49819b687f088f8 (diff) | |
download | ydb-5d50718e66d9c037dc587a0211110b7d25a66185.tar.gz |
Restoring authorship annotation for Mikhail Borisov <borisov.mikhail@gmail.com>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/yson_pull/range.h')
-rw-r--r-- | library/cpp/yson_pull/range.h | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/library/cpp/yson_pull/range.h b/library/cpp/yson_pull/range.h index d602d79911..f4fcf3f206 100644 --- a/library/cpp/yson_pull/range.h +++ b/library/cpp/yson_pull/range.h @@ -1,35 +1,35 @@ -#pragma once - -#include "reader.h" - -#include <util/generic/iterator.h> - -namespace NYsonPull { +#pragma once + +#include "reader.h" + +#include <util/generic/iterator.h> + +namespace NYsonPull { class TStreamEventsRange: public TInputRangeAdaptor<TStreamEventsRange> { TReader Reader_; bool AtEnd; - + public: - TStreamEventsRange(THolder<NInput::IStream> stream, EStreamType mode) + TStreamEventsRange(THolder<NInput::IStream> stream, EStreamType mode) : Reader_{std::move(stream), mode} , AtEnd(false) { } - + const TEvent* Last() const noexcept { - return &Reader_.LastEvent(); + return &Reader_.LastEvent(); } - + const TEvent* Next() { if (Y_UNLIKELY(AtEnd)) { return nullptr; } - - auto* event = &Reader_.NextEvent(); - if (event->Type() == EEventType::EndStream) { + + auto* event = &Reader_.NextEvent(); + if (event->Type() == EEventType::EndStream) { AtEnd = true; } return event; - } + } }; } |