BaseStreamingResponseHandler

org.llm4s.llmconnect.streaming.BaseStreamingResponseHandler

Base implementation of StreamingResponseHandler with common functionality

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Concrete methods

override def cleanup(): Unit

Clean up resources

Clean up resources

Attributes

Definition Classes

Get the final completion after streaming is done

Get the final completion after streaming is done

Attributes

Definition Classes
override def handleError(error: LLMError): Unit

Handle error during streaming

Handle error during streaming

Attributes

Definition Classes
override def isComplete: Boolean

Check if streaming is complete

Check if streaming is complete

Attributes

Definition Classes
protected def markComplete(): Unit

Inherited and Abstract methods

def processChunk(chunk: String): Result[Option[StreamedChunk]]

Process a streaming chunk

Process a streaming chunk

Attributes

Inherited from:
StreamingResponseHandler

Concrete fields

protected var complete: Boolean
protected var streamingError: Option[LLMError]