aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/yson_pull/range.h
diff options
context:
space:
mode:
authorMikhail Borisov <borisov.mikhail@gmail.com>2022-02-10 16:45:39 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:39 +0300
commita6a92afe03e02795227d2641b49819b687f088f8 (patch)
treef6984a1d27d5a7ec88a6fdd6e20cd5b7693b6ece /library/cpp/yson_pull/range.h
parentc6dc8b8bd530985bc4cce0137e9a5de32f1087cb (diff)
downloadydb-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.h32
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;
- }
+ }
};
}