This is an automated email from the ASF dual-hosted git repository. bashirbekov pushed a commit to branch draft-sans in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 22dbaae8cd6d9d0898bea495ca0841170066527f Merge: b1d6fa54 35573cf1 Author: haze518 <[email protected]> AuthorDate: Sun Jul 20 07:17:21 2025 +0600 Merge branch 'draft-sans' of https://github.com/apache/iggy into draft-sans core/sdk/src/connection/tcp/mod.rs | 1 + core/sdk/src/driver/mod.rs | 1 + core/sdk/src/driver/new_tcp.rs | 62 +++++++++++++++++++++++ core/sdk/src/proto/connection.rs | 90 +++++++++++++++++++++++++++++++-- core/sdk/src/quic/quick_client.rs | 2 +- core/sdk/src/tcp/tcp_client.rs | 1 + core/sdk/src/transport_adapter/async.rs | 18 ------- 7 files changed, 153 insertions(+), 22 deletions(-) diff --cc core/sdk/src/transport_adapter/async.rs index dfda5105,7dda9027..57ebee0d --- a/core/sdk/src/transport_adapter/async.rs +++ b/core/sdk/src/transport_adapter/async.rs @@@ -48,21 -47,8 +48,9 @@@ wher id: AtomicU64::new(0), driver: Arc::new(driver), events: broadcast(1000), + tx, } } - // async fn send_with_response<T: Command>(&self, command: &T) -> Result<RespFut, IggyError> { - // self.ensure_connected().await?; - - // let (tx, rx) = runtime::oneshot::<Bytes>(); - // let current_id = self.id.fetch_add(1, std::sync::atomic::Ordering::SeqCst); - - // self.core.lock().await.write(command, current_id)?; - // self.driver.register(current_id, tx); - // self.notify.notify_waiters(); - - // Ok(RespFut { rx: rx }) - // } pub async fn connect(&self) -> Result<(), IggyError> { let mut order = self.core.lock().await.start_connect()?;
