安装

• Std

  [dependencies]
  peekable = "0.2"
  

• Tokio I/O

  [dependencies]
  peekable = { version = "0.2", features = ["tokio"] }
  

• Futures I/O

  [dependencies]
  peekable = { version = "0.2", features = ["future"] }
  

示例

• Std

  use std::{net::TcpStream, io::Read};
  use peekable::Peekable;
  
  let conn = TcpStream::connect("127.0.0.1:8080").unwrap();
  let mut peekable = Peekable::from(conn);
  
  let mut peeked = [0; 16];
  peekable.peek_exact(&mut peeked).unwrap();
  
  let mut readed = [0; 16];
  peekable.read_exact(&mut readed).unwrap();
  
  assert_eq!(peeked, readed);
  

• Tokio I/O

  use tokio::{net::TcpStream, io::AsyncReadExt};
  use peekable::tokio::AsyncPeekable;
  
  let conn = TcpStream::connect("127.0.0.1:8080").await.unwrap();
  let mut peekable = AsyncPeekable::from(conn);
  
  let mut peeked = [0; 16];
  peekable.peek_exact(&mut peeked).await.unwrap();
  
  let mut readed = [0; 16];
  peekable.read_exact(&mut readed).await.unwrap();
  
  assert_eq!(peeked, readed);
  

• Futures I/O

  use async_std::net::TcpStream;
  use futures::AsyncReadExt;
  use peekable::future::AsyncPeekable;
  
  let conn = TcpStream::connect("127.0.0.1:8080").await.unwrap();
  let mut peekable = AsyncPeekable::from(conn);
  
  let mut peeked = [0; 16];
  peekable.peek_exact(&mut peeked).await.unwrap();
  
  let mut readed = [0; 16];
  peekable.read_exact(&mut readed).await.unwrap();
  
  assert_eq!(peeked, readed);
  

许可证

peekable 在MIT许可证和Apache许可证（版本2.0）下。

请参阅 LICENSE-APACHE、LICENSE-MIT 以获取详细信息。

版权所有 (c) 2024 Al Liu。