fix: rename create_response_steam to create_response_stream (#1615)

lib/runtime/src/pipeline/network/ingress/push_handler.rs

@@ -62,7 +62,7 @@ where
         // todo - eventually have a handler class which will returned an abstracted object, but for now,
         // we only support tcp here, so we can just unwrap the connection info
         tracing::trace!("creating tcp response stream");
-        let mut publisher = tcp::client::TcpClient::create_response_steam(
+        let mut publisher = tcp::client::TcpClient::create_response_stream(
             request.context(),
             control_msg.connection_info,
         )

lib/runtime/src/pipeline/network/tcp.rs

@@ -135,7 +135,7 @@ mod tests {
 
         // connect to the server socket
         let mut send_stream =
-            client::TcpClient::create_response_steam(context_rank1.context(), connection_info)
+            client::TcpClient::create_response_stream(context_rank1.context(), connection_info)
                 .await
                 .unwrap();
         println!("Client connected");

lib/runtime/src/pipeline/network/tcp/client.rs

@@ -72,7 +72,7 @@ impl TcpClient {
         }
     }
 
-    pub async fn create_response_steam(
+    pub async fn create_response_stream(
         context: Arc<dyn AsyncEngineContext>,
         info: ConnectionInfo,
     ) -> Result<StreamSender> {
@@ -120,7 +120,7 @@ impl TcpClient {
             Ok(hb) => hb,
             Err(err) => {
                 return Err(error!(
-                    "create_response_steam: Error converting CallHomeHandshake to JSON array: {err:#}"
+                    "create_response_stream: Error converting CallHomeHandshake to JSON array: {err:#}"
                 ));
             }
         };