From 4545838ce98ab5f14d30fbadcd15e03ca9cdad28 Mon Sep 17 00:00:00 2001
From: Martin Hoffmann <martin@nlnetlabs.nl>
Date: Wed, 29 May 2024 15:28:46 +0200
Subject: [PATCH] Remove tokio-stream dependency.

---
 Cargo.toml        | 3 +--
 src/rtr/server.rs | 2 +-
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/Cargo.toml b/Cargo.toml
index 4b061e6..16d0f49 100644
--- a/Cargo.toml
+++ b/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
diff --git a/src/rtr/server.rs b/src/rtr/server.rs
index 22ee425..77b3d8c 100644
--- a/src/rtr/server.rs
+++ b/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;