module Anthropic::Internal::Type::BaseStream

def close = Anthropic::Internal::Util.close_fused!(@iterator)

Returns:
  • (void) - 
def close = Anthropic::Internal::Util.close_fused!(@iterator)

def defer_closing(stream) = ->(_id) { Anthropic::Internal::Util.close_fused!(stream) }

Other tags:
    See: https://rubyapi.org/3.1/o/objectspace#method-c-define_finalizer -

Returns:
  • (Proc) -

Parameters:
  • stream (Enumerable) -- 
    def defer_closing(stream) = ->(_id) { Anthropic::Internal::Util.close_fused!(stream) }

    def each(&blk)

    Returns:
    • (void) -

    Other tags:
      Yieldparam: -

    Parameters:
    • blk (Proc) -- 
    def each(&blk)
  unless block_given?
    raise ArgumentError.new("A block must be given to ##{__method__}")
  end
  @iterator.each(&blk)
end

    def initialize(model:, url:, status:, response:, stream:)

    Parameters:
    • stream (Enumerable) --
    • response (Net::HTTPResponse) --
    • status (Integer) --
    • url (URI::Generic) --
    • model (Class, Anthropic::Internal::Type::Converter) --

      • Other tags:
        Api: - private 
      def initialize(model:, url:, status:, response:, stream:)
  @model = model
  @url = url
  @status = status
  @response = response
  @stream = stream
  @iterator = iterator
  ObjectSpace.define_finalizer(self, Anthropic::Internal::Type::BaseStream.defer_closing(@stream))
end

      def iterator = (raise NotImplementedError)

      Returns:
      • (Enumerable>) -

      Other tags:
        Api: - private 
      def iterator = (raise NotImplementedError)

      def to_enum = @iterator

      Returns:
      • (Enumerator>) - 
      def to_enum = @iterator