U DAfT@sxddlmZmZddlmZddlmZmZeddddZeegdfe dd d Z e eeegdfd d d Z dS))CallableOptional)StreamingChunk)deserialize_callableserialize_callableN)chunkreturncCst|jddddS)z Default callback function for streaming responses. Prints the tokens of the first completion to stdout as soon as they are received T)flushendN)printcontent)rrH/tmp/pip-unpacked-wheel-z752163x/haystack/components/generators/utils.pyprint_streaming_chunk sr)streaming_callbackrcCst|S)z Serializes the streaming callback handler. :param streaming_callback: The streaming callback handler function :returns: The full path of the streaming callback handler function )r)rrrrserialize_callback_handlers r) callback_namercCst|S)a5 Deserializes the streaming callback handler. :param callback_name: The full path of the streaming callback handler function :returns: The streaming callback handler function :raises DeserializationError: If the streaming callback handler function cannot be found )r)rrrrdeserialize_callback_handler s r) typingrrZhaystack.dataclassesrZhaystack.utilsrrrstrrrrrrrs