diff --git a/Cargo.toml b/Cargo.toml index affa5ad..0871b04 100755 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "sol-trade-sdk" -version = "1.2.2" +version = "1.2.3" edition = "2021" authors = [ "William ", diff --git a/README.md b/README.md index afe9f99..da99f50 100644 --- a/README.md +++ b/README.md @@ -87,14 +87,14 @@ Add the dependency to your `Cargo.toml`: ```toml # Add to your Cargo.toml -sol-trade-sdk = { path = "./sol-trade-sdk", version = "1.2.2" } +sol-trade-sdk = { path = "./sol-trade-sdk", version = "1.2.3" } ``` ### Use crates.io ```toml # Add to your Cargo.toml -sol-trade-sdk = "1.2.2" +sol-trade-sdk = "1.2.3" ``` ## 🛠️ Usage Examples diff --git a/README_CN.md b/README_CN.md index 6012855..dbe48ce 100755 --- a/README_CN.md +++ b/README_CN.md @@ -87,14 +87,14 @@ git clone https://github.com/0xfnzero/sol-trade-sdk ```toml # 添加到您的 Cargo.toml -sol-trade-sdk = { path = "./sol-trade-sdk", version = "1.2.2" } +sol-trade-sdk = { path = "./sol-trade-sdk", version = "1.2.3" } ``` ### 使用 crates.io ```toml # 添加到您的 Cargo.toml -sol-trade-sdk = "1.2.2" +sol-trade-sdk = "1.2.3" ``` ## 🛠️ 使用示例 diff --git a/src/trading/core/parallel.rs b/src/trading/core/parallel.rs index 681de26..071da5e 100755 --- a/src/trading/core/parallel.rs +++ b/src/trading/core/parallel.rs @@ -88,7 +88,7 @@ async fn parallel_execute( return Err(anyhow!("No Rpc Default Swqos configured.")); } let cores = core_affinity::get_core_ids().unwrap(); - let mut handles: Vec>> = + let mut handles: Vec)>>> = Vec::with_capacity(swqos_clients.len()); let instructions = Arc::new(instructions); @@ -194,7 +194,7 @@ async fn parallel_execute( ); if let Some(signature) = transaction.signatures.first() { - return Ok((success, signature.clone(), err.unwrap())); + return Ok((success, signature.clone(), err)); } else { return Err(anyhow!("Transaction has no signatures")); } @@ -237,7 +237,9 @@ async fn parallel_execute( if success { return Ok((success, sig)); } - errors.push(format!("Task error: {}", err)); + if let Some(err) = err { + errors.push(format!("Task error: {}", err)); + } last_signature = Some(sig); } Ok(Err(e)) => errors.push(format!("Task error: {}", e)),