Class: LLM::MessageQueue

Inherits:

Object

• Object
• LLM::MessageQueue

Includes:

Enumerable

Defined in:

lib/llm/message_queue.rb

Overview

LLM::MessageQueue provides an Enumerable object that yields each message in a conversation on-demand, and only sends a request to the LLM when a response is needed.

Instance Method Summary

• #<<(message) ⇒ void (also: #push)
• #each {|LLM::Message| ... } ⇒ void
• #initialize(provider) ⇒ LLM::MessageQueue constructor

Constructor Details

#initialize(provider) ⇒ LLM::MessageQueue

Parameters:

• provider (LLM::Provider)

# File 'lib/llm/message_queue.rb', line 14

def initialize(provider)
  @provider = provider
  @messages = []
end

Instance Method Details

#<<(message) ⇒ void Also known as: push

This method returns an undefined value.

Parameters:

• message (Object) —

  A message to add to the conversation thread

# File 'lib/llm/message_queue.rb', line 33

def <<(message)
  @messages << message
end

#each {|LLM::Message| ... } ⇒ void

This method returns an undefined value.

Yields:

• (LLM::Message) —

  Yields each message in the conversation thread

Raises:

• (NotImplementedError) —

  When the method is not implemented by a subclass

# File 'lib/llm/message_queue.rb', line 24

def each
  @messages = complete! unless @messages.grep(LLM::Message).size == @messages.size
  @messages.each { yield(_1) }
end