1 files changed, 26 insertions, 0 deletions
diff --git a/lib/bulk_imports/pipeline/extracted_data.rb b/lib/bulk_imports/pipeline/extracted_data.rb
new file mode 100644
index 00000000000..685a91a4afe
--- /dev/null
+++ b/lib/bulk_imports/pipeline/extracted_data.rb
@@ -0,0 +1,26 @@
+# frozen_string_literal: true
+
+module BulkImports
+  module Pipeline
+    class ExtractedData
+      attr_reader :data
+
+      def initialize(data: nil, page_info: {})
+        @data = Array.wrap(data)
+        @page_info = page_info
+      end
+
+      def has_next_page?
+        @page_info['has_next_page']
+      end
+
+      def next_page
+        @page_info['end_cursor']
+      end
+
+      def each(&block)
+        data.each(&block)
+      end
+    end
+  end
+end