Remove tokio-stream dependency

Cargo.lock

@@ -231,7 +231,6 @@ dependencies = [
  "strum",
  "tempfile",
  "tokio",
- "tokio-stream",
  "tokio-util",
  "walkdir",
  "whoami",
@@ -1131,18 +1130,6 @@ dependencies = [
  "syn",
 ]
 
-[[package]]
-name = "tokio-stream"
-version = "0.1.7"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "7b2f3f698253f03119ac0102beaa64f67a67e08074d03a22d18784104543727f"
-dependencies = [
- "futures-core",
- "pin-project-lite",
- "tokio",
- "tokio-util",
-]
-
 [[package]]
 name = "tokio-util"
 version = "0.6.7"

Cargo.toml

@@ -29,7 +29,6 @@ serde_cbor = "0.11.1"
 serde_json = "1.0.64"
 strum = { version = "0.21.0", features = ["derive"] }
 tokio = { version = "1.9.0", features = ["full"] }
-tokio-stream = { version = "0.1.7", features = ["sync"] }
 tokio-util = { version = "0.6.7", features = ["codec"] }
 walkdir = "2.3.2"
 

src/core/net/transport/mod.rs

@@ -2,6 +2,7 @@ use crate::core::{constants::SALT_LEN, net::SecretKey};
 use codec::DistantCodec;
 use derive_more::{Display, Error, From};
 use futures::SinkExt;
+use futures::StreamExt;
 use k256::{ecdh::EphemeralSecret, EncodedPoint, PublicKey};
 use log::*;
 use orion::{
@@ -14,7 +15,6 @@ use orion::{
 use serde::{de::DeserializeOwned, Serialize};
 use std::{marker::Unpin, sync::Arc};
 use tokio::io::{self, AsyncRead, AsyncWrite};
-use tokio_stream::StreamExt;
 use tokio_util::codec::{Framed, FramedRead, FramedWrite};
 
 mod codec;