Currently, Hayhooks provides streaming_generator and async_streaming_generator utility functions that can be used to stream the pipeline chunks to the client. Info.

These functions work by attaching a streaming_callback to the components in the Pipeline that support streaming, and then streaming the generated chunks.

Even if the Pipeline is executed, the final result is not returned.

In some cases, it would be helpful to have access to both the streamed output and the final result.

Think for example of a RAG pipeline where we also want to show users the original source documents (coming from a Retriever or an AnswerBuilder).