Remove tokio-stream dependency. (#290)

This PR removes the tokio-stream dependency and replaces its use with futures-util.

Cargo.toml

@@ -30,7 +30,6 @@ ring            = { version = "0.17.6", optional = true }
 serde           = { version = "1.0.103", optional = true, features = [ "derive" ] }
 serde_json      = { version = "1.0.40", optional = true }
 tokio           = { version = "1.0", optional = true, features = ["io-util",  "net", "rt", "sync", "time"] }
-tokio-stream    = { version = "0.1", optional = true }
 uuid            = "1.1"
 untrusted       = { version = "0.9", optional = true }
 
@@ -47,7 +46,7 @@ ca         = [ "repository", "serde-support", "rrdp" ]
 crypto     = [ "bcder", "ring", "untrusted" ]
 repository = [ "bcder", "crypto" ]
 rrdp       = [ "xml", "ring" ]
-rtr        = [ "futures-util", "tokio", "tokio-stream" ]
+rtr        = [ "futures-util", "tokio" ]
 slurm      = [ "rtr", "serde-support", "serde_json" ]
 
 # Feature that provides compatibility with (technically incorrect) objects

src/rtr/server.rs

@@ -9,11 +9,11 @@ use std::io;
 use futures_util::future;
 use futures_util::pin_mut;
 use futures_util::future::Either;
+use futures_util::stream::{Stream, StreamExt};
 use log::debug;
 use tokio::io::{AsyncRead, AsyncWrite, AsyncWriteExt};
 use tokio::sync::broadcast;
 use tokio::task::spawn;
-use tokio_stream::{Stream, StreamExt};
 use super::pdu;
 use super::payload::{Action, PayloadRef, Timing};
 use super::state::State;