diff --git a/kube-client/src/api/remote_command.rs b/kube-client/src/api/remote_command.rs index a0a78572a..069ffb440 100644 --- a/kube-client/src/api/remote_command.rs +++ b/kube-client/src/api/remote_command.rs @@ -350,7 +350,7 @@ where let mut vec = Vec::with_capacity(new_size.len() + 1); vec.push(RESIZE_CHANNEL); vec.extend_from_slice(&new_size[..]); - server_send.send(ws::Message::Binary(vec)).await.map_err(Error::SendTerminalSize)?; + server_send.send(ws::Message::Binary(vec.into())).await.map_err(Error::SendTerminalSize)?; }, None => { have_terminal_size_rx = false; @@ -379,9 +379,9 @@ async fn filter_message(wsm: Result) -> Option 1 => match bin[0] { - STDOUT_CHANNEL => Some(Ok(Message::Stdout(bin))), - STDERR_CHANNEL => Some(Ok(Message::Stderr(bin))), - STATUS_CHANNEL => Some(Ok(Message::Status(bin))), + STDOUT_CHANNEL => Some(Ok(Message::Stdout(bin.into()))), + STDERR_CHANNEL => Some(Ok(Message::Stderr(bin.into()))), + STATUS_CHANNEL => Some(Ok(Message::Status(bin.into()))), // We don't receive messages to stdin and resize channels. _ => None, },