mirror of
https://github.com/MindWorkAI/AI-Studio.git
synced 2025-05-03 09:39:47 +00:00
Renamed read_pdf function to stream_pdf for clarity
This commit is contained in:
parent
16a97d943e
commit
10d4a2d353
@ -92,7 +92,7 @@ async fn stream_data(file_path: &str) -> Result<ChunkStream> {
|
|||||||
|
|
||||||
_ => match fmt.kind() {
|
_ => match fmt.kind() {
|
||||||
Kind::Document => match fmt {
|
Kind::Document => match fmt {
|
||||||
FileFormat::PortableDocumentFormat => read_pdf(file_path).await?,
|
FileFormat::PortableDocumentFormat => stream_pdf(file_path).await?,
|
||||||
FileFormat::MicrosoftWordDocument => {
|
FileFormat::MicrosoftWordDocument => {
|
||||||
convert_with_pandoc(file_path, "docx", TO_MARKDOWN).await?
|
convert_with_pandoc(file_path, "docx", TO_MARKDOWN).await?
|
||||||
}
|
}
|
||||||
@ -146,7 +146,7 @@ async fn stream_text_file(file_path: &str) -> Result<ChunkStream> {
|
|||||||
Ok(Box::pin(stream))
|
Ok(Box::pin(stream))
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn read_pdf(file_path: &str) -> Result<ChunkStream> {
|
async fn stream_pdf(file_path: &str) -> Result<ChunkStream> {
|
||||||
let path = file_path.to_owned();
|
let path = file_path.to_owned();
|
||||||
let (tx, rx) = mpsc::channel(10);
|
let (tx, rx) = mpsc::channel(10);
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user