Update examples to latest Tokio/Futures

Cargo.toml

@@ -20,3 +20,4 @@ edition = "2018"
 thiserror = "1.0"
 tokio = { version = "1", features = ["rt", "rt-multi-thread", "net", "io-util", "time", "macros"] }
 tokio-util = { version = "0.7", features = ["codec"] }
+futures = "0.3.30"

examples/simple.rs

@@ -1,18 +1,18 @@
 use rmonitor::codec::RMonitorDecoder;
 use std::error::Error;
 use std::time::Duration;
+use futures::StreamExt;
 use tokio::net::TcpStream;
-use tokio::stream::StreamExt;
 use tokio::time::timeout;
 use tokio_util::codec::FramedRead;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error>> {
-    let stream = TcpStream::connect("127.0.0.1:4000").await?;
+    let stream = TcpStream::connect("127.0.0.1:50000").await?;
 
     let mut reader = FramedRead::new(stream, RMonitorDecoder::new_with_max_length(2048));
 
-    while let Ok(Some(Ok(event))) = timeout(Duration::from_millis(10), reader.next()).await {
+    while let Ok(Some(Ok(event))) = timeout(Duration::from_secs(5), reader.next()).await {
         println!("{:?}", event);
     }
 

examples/sync.rs

@@ -1,4 +1,4 @@
-use bytes::{BufMut, BytesMut};
+use tokio_util::bytes::{BufMut, BytesMut};
 use rmonitor::codec::RMonitorDecoder;
 use std::io::Read;
 use std::net::TcpStream;

src/lib.rs

@@ -10,7 +10,7 @@
 //! use rmonitor::RMonitorDecoder;
 //! # use std::error::Error;
 //! use tokio::net::TcpStream;
-//! # use tokio::stream::StreamExt;
+//! use futures::stream::StreamExt;
 //! use tokio_util::codec::FramedRead;
 //!
 //! #[tokio::main]