reduce changes

Cargo.toml

@@ -2,4 +2,4 @@
 members = [
     "crates/socket",
     "crates/service"
-]
+]

crates/socket/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "fluvio-socket"
-version = "0.4.3"
+version = "0.4.2"
 edition = "2018"
 authors = ["Fluvio Contributors <[email protected]>"]
 description = "Provide TCP socket wrapper for fluvio protocol"
@@ -35,10 +35,10 @@ pin-project = "1.0.1"
 thiserror = "1.0.20"
 
 # Fluvio dependencies
-fluvio-future = { version = "0.1.12", features = ["net", "zero_copy"] }
+fluvio-future = { version = "0.1.11", features = ["net", "zero_copy"] }
 fluvio-protocol = { version = "0.2.0", features = ["derive", "api", "codec", "store"] }
 
 
 [dev-dependencies]
-fluvio-future = { version = "0.1.12", features = ["fixture", "fs", "native2_tls"] }
+fluvio-future = { version = "0.1.5", features = ["fixture", "fs", "native2_tls"] }
 flv-util = { version = "0.5.0", features = ["fixture"] }

crates/socket/src/sink.rs

@@ -134,7 +134,7 @@ where
                     self.get_mut_tcp_sink().send(bytes).await?;
                 }
                 StoreValue::FileSlice(f_slice) => {
-                    if f_slice.is_empty() {
+                    if f_slice.len() == 0 {
                         debug!("empty slice, skipping");
                     } else {
                         debug!(

crates/socket/src/socket.rs

@@ -121,7 +121,7 @@ impl<S> From<(InnerFlvSink<S>, InnerFlvStream<S>)> for InnerFlvSocket<S> {
 
 impl FlvSocket {
     pub async fn connect(addr: &str) -> Result<Self, FlvSocketError> {
-        Self::connect_with_connector(addr, &DefaultTcpDomainConnector).await
+        Self::connect_with_connector(addr, &DefaultTcpDomainConnector::new()).await
     }
 }