Module: Anthropic::Internal::Type::BaseStream Private

Includes:
Enumerable
Included in:
Helpers::Streaming::MessageStream, JsonLStream, Stream
Defined in:
lib/anthropic/internal/type/base_stream.rb

Overview

This module is part of a private API. You should avoid using this module if possible, as it may be removed or be changed in the future.

This module provides a base implementation for streaming responses in the SDK.

See Also:

Generic:

  • Elem

API:

  • private

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#headers ⇒ Hash{String=>String} (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns:

API:

  • private



20
21
22
 
# File 'lib/anthropic/internal/type/base_stream.rb', line 20

def headers
  @headers
end

#status ⇒ Integer (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns:

API:

  • private



17
18
19
 
# File 'lib/anthropic/internal/type/base_stream.rb', line 17

def status
  @status
end

Instance Method Details

#close ⇒ void

This method returns an undefined value.

API:

  • public



25
 
# File 'lib/anthropic/internal/type/base_stream.rb', line 25

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

#each(&blk) {|| ... } ⇒ void

This method returns an undefined value.

Parameters:

Yield Parameters:

  • (generic<Elem>)

API:

  • public



38
39
40
41
42
43
 
# File 'lib/anthropic/internal/type/base_stream.rb', line 38

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

#initialize(model:, url:, status:, headers:, response:, unwrap:, stream:) ⇒ void

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Parameters:

API:

  • private



61
62
63
64
65
66
67
68
69
70
 
# File 'lib/anthropic/internal/type/base_stream.rb', line 61

def initialize(model:, url:, status:, headers:, response:, unwrap:, stream:)
  @model = model
  @url = url
  @status = status
  @headers = headers
  @response = response
  @unwrap = unwrap
  @stream = stream
  @iterator = iterator
end

#inspect ⇒ String

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns:

API:

  • private



75
76
77
78
79
 
# File 'lib/anthropic/internal/type/base_stream.rb', line 75

def inspect
  model = Anthropic::Internal::Type::Converter.inspect(@model, depth: 1)

  "#<#{self.class}[#{model}]:0x#{object_id.to_s(16)}>"
end

#to_enum ⇒ Enumerator<generic<Elem>> Also known as: enum_for

Returns:

API:

  • public



48
 
# File 'lib/anthropic/internal/type/base_stream.rb', line 48

def to_enum = @iterator