hotfix for run plugin call post api
This commit is contained in:
parent
3029dcb2f6
commit
fd3568c459
|
@ -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()
|
||||
|
@ -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();
|
||||
|
||||
|
@ -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);
|
||||
}
|
||||
|
@ -126,7 +126,7 @@ pub async fn stream_fetch(
|
|||
}
|
||||
}
|
||||
};
|
||||
println!("Response: {:?}", response);
|
||||
// println!("Response: {:?}", response);
|
||||
Ok(response)
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue