diff options
author | Mikhail Borisov <borisov.mikhail@gmail.com> | 2022-02-10 16:45:39 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:39 +0300 |
commit | a6a92afe03e02795227d2641b49819b687f088f8 (patch) | |
tree | f6984a1d27d5a7ec88a6fdd6e20cd5b7693b6ece /library/cpp/yson_pull/range.h | |
parent | c6dc8b8bd530985bc4cce0137e9a5de32f1087cb (diff) | |
download | ydb-a6a92afe03e02795227d2641b49819b687f088f8.tar.gz |
Restoring authorship annotation for Mikhail Borisov <borisov.mikhail@gmail.com>. Commit 1 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 f4fcf3f206..d602d79911 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; - } + } }; } |