lib/gitlab/ci/build/artifacts/adapters/raw_stream.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

module Gitlab
  module Ci
    module Build
      module Artifacts
        module Adapters
          class RawStream
            attr_reader :stream

            InvalidStreamError = Class.new(StandardError)

            def initialize(stream)
              raise InvalidStreamError, "Stream is required" unless stream

              @stream = stream
            end

            def each_blob
              stream.seek(0)

              yield(stream.read, 'raw') unless stream.eof?
            end
          end
        end
      end
    end
  end
end