summaryrefslogtreecommitdiffstats
path: root/src/tty.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/tty.rs')
-rw-r--r--src/tty.rs7
1 files changed, 3 insertions, 4 deletions
diff --git a/src/tty.rs b/src/tty.rs
index a26846f..b4232ad 100644
--- a/src/tty.rs
+++ b/src/tty.rs
@@ -1,13 +1,12 @@
//! Types for working with docker TTY streams
use crate::{Error, Result};
-use bytes::{BigEndian, ByteOrder};
use futures_util::{
io::{AsyncRead, AsyncReadExt, AsyncWrite},
stream::{Stream, TryStreamExt},
};
use pin_project::pin_project;
-use std::io;
+use std::{convert::TryInto, io};
/// An enum representing a chunk of TTY text streamed from a Docker container.
///
@@ -54,7 +53,7 @@ async fn decode_chunk<S>(mut stream: S) -> Option<(Result<TtyChunk>, S)>
where
S: AsyncRead + Unpin,
{
- let mut header_bytes = vec![0u8; 8];
+ let mut header_bytes = [0u8; 8];
match stream.read_exact(&mut header_bytes).await {
Err(e) if e.kind() == futures_util::io::ErrorKind::UnexpectedEof => return None,
@@ -63,7 +62,7 @@ where
}
let size_bytes = &header_bytes[4..];
- let data_length = BigEndian::read_u32(size_bytes);
+ let data_length = u32::from_be_bytes(size_bytes.try_into().unwrap());
let mut data = vec![0u8; data_length as usize];