mirascope.core.base.stream | Mirascope
MirascopeLilypad

mirascope.core.base.stream

Module stream

This module contains the base classes for streaming responses from LLMs.

Class BaseStream

A base class for streaming responses from LLMs.

Bases: Generic[_BaseCallResponseT, _BaseCallResponseChunkT, _UserMessageParamT, _AssistantMessageParamT, _ToolMessageParamT, _MessageParamT, _BaseToolT, _ToolSchemaT, _BaseDynamicConfigT, _BaseCallParamsT, _FinishReason], ABC

Attributes

NameTypeDescription
streamGenerator[tuple[_BaseCallResponseChunkT, _BaseToolT | None], None, None] | AsyncGenerator[tuple[_BaseCallResponseChunkT, _BaseToolT | None], None]-
contentstr-
metadataMetadata-
tool_typeslist[type[_BaseToolT]] | None-
call_response_typetype[_BaseCallResponseT]-
modelstr-
prompt_templatestr | None-
fn_argsdict[str, Any] | None-
dynamic_config_BaseDynamicConfigT-
messageslist[_MessageParamT]-
call_params_BaseCallParamsT-
call_kwargsBaseCallKwargs[_ToolSchemaT]-
user_message_param_UserMessageParamT | None-
message_param_AssistantMessageParamT-
input_tokensint | float | None-
cached_tokensint | float | None-
output_tokensint | float | None-
idstr | None-
finish_reasonslist[_FinishReason] | None-
start_timefloat-
end_timefloat-
providerProvider-
cost_metadataCostMetadataReturns metadata needed for cost calculation.
costfloat | NoneCalculate the cost of this streaming API call.

Function tool_message_params

Returns the tool message parameters for tool call results.

Parameters

NameTypeDescription
selfAny-
tools_and_outputslist[tuple[_BaseToolT, JsonableType]]The list of tools and their outputs from which the tool message parameters should be constructed.

Returns

TypeDescription
list[_ToolMessageParamT]-

Function construct_call_response

Constructs the call response.

Parameters

NameTypeDescription
selfAny-

Returns

TypeDescription
_BaseCallResponseT-

Function stream_factory

Parameters

NameTypeDescription
TCallResponsetype[_BaseCallResponseT]-
TStreamtype[BaseStream]-
setup_callSameSyncAndAsyncClientSetupCall[_SameSyncAndAsyncClientT, _BaseDynamicConfigT, _AsyncBaseDynamicConfigT, _BaseCallParamsT, _ResponseT, _ResponseChunkT, _AsyncResponseT, _AsyncResponseChunkT, _BaseToolT] | SetupCall[_SyncBaseClientT, _AsyncBaseClientT, _BaseDynamicConfigT, _AsyncBaseDynamicConfigT, _BaseCallParamsT, _ResponseT, _ResponseChunkT, _AsyncResponseT, _AsyncResponseChunkT, _BaseToolT]-
handle_streamHandleStream[_ResponseChunkT, _BaseCallResponseChunkT, _BaseToolT]-
handle_stream_asyncHandleStreamAsync[_AsyncResponseChunkT, _BaseCallResponseChunkT, _BaseToolT]-