Fix warnings
This commit is contained in:
		
							parent
							
								
									9b52f76cf5
								
							
						
					
					
						commit
						2ab71b7667
					
				
					 1 changed files with 3 additions and 7 deletions
				
			
		|  | @ -1,5 +1,4 @@ | ||||||
| use anyhow::Result; | use anyhow::Result; | ||||||
| use futures::StreamExt; |  | ||||||
| use reqwest::Client; | use reqwest::Client; | ||||||
| use serde_json::{json, Value}; | use serde_json::{json, Value}; | ||||||
| use tokio::io::{self, AsyncBufReadExt, AsyncWriteExt, BufReader}; | use tokio::io::{self, AsyncBufReadExt, AsyncWriteExt, BufReader}; | ||||||
|  | @ -68,8 +67,6 @@ async fn http_sse_client() -> Result<()> { | ||||||
|     // Give the server some time to start
 |     // Give the server some time to start
 | ||||||
|     tokio::time::sleep(tokio::time::Duration::from_secs(2)).await; |     tokio::time::sleep(tokio::time::Duration::from_secs(2)).await; | ||||||
| 
 | 
 | ||||||
|     // Connect to the SSE endpoint to get a session ID
 |  | ||||||
|     let mut session_id = String::new(); |  | ||||||
|     let sse_url = "http://127.0.0.1:8080/sse"; |     let sse_url = "http://127.0.0.1:8080/sse"; | ||||||
|     
 |     
 | ||||||
|     println!("Getting session ID from SSE endpoint..."); |     println!("Getting session ID from SSE endpoint..."); | ||||||
|  | @ -84,13 +81,12 @@ async fn http_sse_client() -> Result<()> { | ||||||
| 
 | 
 | ||||||
|     // Parse the first message to get the session ID
 |     // Parse the first message to get the session ID
 | ||||||
|     // In a real implementation, you would properly handle the SSE stream
 |     // In a real implementation, you would properly handle the SSE stream
 | ||||||
|     if let Some(event_data) = response.headers().get("x-accel-buffering") { |     if let None = response.headers().get("x-accel-buffering") { | ||||||
|         // This is just a placeholder - in a real SSE client you would parse the actual event
 |  | ||||||
|         session_id = "example_session_id".to_string(); 
 |  | ||||||
|     } else { |  | ||||||
|         println!("Could not get session ID from SSE endpoint"); |         println!("Could not get session ID from SSE endpoint"); | ||||||
|         return Ok(()); |         return Ok(()); | ||||||
|     } |     } | ||||||
|  |     // This is just a placeholder - in a real SSE client you would parse the actual event
 | ||||||
|  |     let session_id = "example_session_id".to_string(); 
 | ||||||
| 
 | 
 | ||||||
|     // Send a request to search for crates
 |     // Send a request to search for crates
 | ||||||
|     let request_url = format!("{}?sessionId={}", sse_url, session_id); |     let request_url = format!("{}?sessionId={}", sse_url, session_id); | ||||||
|  |  | ||||||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue
	
	 Danielle Jenkins
						Danielle Jenkins