Skip to content

Commit

Permalink
hotfix for run plugin call post api
Browse files Browse the repository at this point in the history
  • Loading branch information
lloydzhou committed Sep 30, 2024
1 parent 3029dcb commit fd3568c
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions src-tauri/src/stream.rs
Original file line number Diff line number Diff line change
Expand Up @@ -47,10 +47,10 @@ pub async fn stream_fetch(
_headers.insert(key.parse::<HeaderName>().unwrap(), value.parse().unwrap());
}

println!("method: {:?}", method);
println!("url: {:?}", url);
println!("headers: {:?}", headers);
println!("headers: {:?}", _headers);
// println!("method: {:?}", method);
// println!("url: {:?}", url);
// println!("headers: {:?}", headers);
// println!("headers: {:?}", _headers);

let method = method.parse::<reqwest::Method>().map_err(|err| format!("failed to parse method: {}", err))?;
let client = Client::builder()
Expand All @@ -66,12 +66,12 @@ pub async fn stream_fetch(

if method == reqwest::Method::POST || method == reqwest::Method::PUT || method == reqwest::Method::PATCH {
let body = bytes::Bytes::from(body);
println!("body: {:?}", body);
// println!("body: {:?}", body);
request = request.body(body);
}

println!("client: {:?}", client);
println!("request: {:?}", request);
// println!("client: {:?}", client);
// println!("request: {:?}", request);

let response_future = request.send();

Expand All @@ -94,7 +94,7 @@ pub async fn stream_fetch(
while let Some(chunk) = stream.next().await {
match chunk {
Ok(bytes) => {
println!("chunk: {:?}", bytes);
// println!("chunk: {:?}", bytes);
if let Err(e) = window.emit(event_name, ChunkPayload{ request_id, chunk: bytes }) {
println!("Failed to emit chunk payload: {:?}", e);
}
Expand Down Expand Up @@ -126,7 +126,7 @@ pub async fn stream_fetch(
}
}
};
println!("Response: {:?}", response);
// println!("Response: {:?}", response);
Ok(response)
}

0 comments on commit fd3568c

Please sign in to comment.