mirror of
https://github.com/fluencelabs/rust-libp2p
synced 2025-08-01 01:11:58 +00:00
Merge pull request #58 from tomaka/tokio-core-dep
Remove the tokio-core dependency where not necessary
This commit is contained in:
@@ -9,9 +9,9 @@ datastore = { path = "../datastore" }
|
||||
futures = "0.1.0"
|
||||
owning_ref = "0.3.3"
|
||||
multiaddr = "0.2"
|
||||
multihash = "0.7.0"
|
||||
serde = "1.0"
|
||||
serde_derive = "1.0"
|
||||
|
||||
[dev-dependencies]
|
||||
multihash = "0.7.0"
|
||||
tempfile = "2.2"
|
||||
|
@@ -35,7 +35,6 @@ extern crate base58;
|
||||
extern crate datastore;
|
||||
extern crate futures;
|
||||
extern crate multiaddr;
|
||||
extern crate multihash;
|
||||
extern crate owning_ref;
|
||||
extern crate serde;
|
||||
#[macro_use]
|
||||
|
@@ -29,11 +29,11 @@
|
||||
|
||||
macro_rules! peerstore_tests {
|
||||
({$create_peerstore:expr} $({$stmt:stmt})*) => {
|
||||
extern crate multihash;
|
||||
use std::thread;
|
||||
use std::time::Duration;
|
||||
use {Peerstore, PeerAccess};
|
||||
use multiaddr::Multiaddr;
|
||||
use multihash;
|
||||
|
||||
#[test]
|
||||
fn initially_empty() {
|
||||
|
@@ -12,6 +12,8 @@ rand = "0.3.17"
|
||||
ring = { version = "0.12.1", features = ["rsa_signing"] }
|
||||
rust-crypto = "^0.2"
|
||||
rw-stream-sink = { path = "../rw-stream-sink" }
|
||||
tokio-core = "0.1.6"
|
||||
tokio-io = "0.1.0"
|
||||
untrusted = "0.6.0"
|
||||
|
||||
[dev-dependencies]
|
||||
tokio-core = "0.1.6"
|
||||
|
@@ -57,6 +57,7 @@ pub fn full_codec<S>(
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
extern crate tokio_core;
|
||||
use super::DecoderMiddleware;
|
||||
use super::EncoderMiddleware;
|
||||
use super::full_codec;
|
||||
@@ -71,9 +72,9 @@ mod tests {
|
||||
use ring::hmac::SigningKey;
|
||||
use ring::hmac::VerificationKey;
|
||||
use std::io::Error as IoError;
|
||||
use tokio_core::net::TcpListener;
|
||||
use tokio_core::net::TcpStream;
|
||||
use tokio_core::reactor::Core;
|
||||
use self::tokio_core::net::TcpListener;
|
||||
use self::tokio_core::net::TcpStream;
|
||||
use self::tokio_core::reactor::Core;
|
||||
use tokio_io::codec::length_delimited::Framed;
|
||||
|
||||
#[test]
|
||||
|
@@ -443,6 +443,7 @@ fn stretch_key(key: &SigningKey, result: &mut [u8]) {
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
extern crate tokio_core;
|
||||
use super::handshake;
|
||||
use super::stretch_key;
|
||||
use futures::Future;
|
||||
@@ -451,9 +452,9 @@ mod tests {
|
||||
use ring::hmac::SigningKey;
|
||||
use ring::signature::RSAKeyPair;
|
||||
use std::sync::Arc;
|
||||
use tokio_core::net::TcpListener;
|
||||
use tokio_core::net::TcpStream;
|
||||
use tokio_core::reactor::Core;
|
||||
use self::tokio_core::net::TcpListener;
|
||||
use self::tokio_core::net::TcpStream;
|
||||
use self::tokio_core::reactor::Core;
|
||||
use untrusted::Input;
|
||||
|
||||
#[test]
|
||||
|
@@ -40,7 +40,6 @@ extern crate protobuf;
|
||||
extern crate rand;
|
||||
extern crate ring;
|
||||
extern crate rw_stream_sink;
|
||||
extern crate tokio_core;
|
||||
extern crate tokio_io;
|
||||
extern crate untrusted;
|
||||
|
||||
|
@@ -9,7 +9,6 @@ multiaddr = "0.2.0"
|
||||
multistream-select = { path = "../multistream-select" }
|
||||
futures = "0.1"
|
||||
smallvec = "0.5"
|
||||
tokio-core = "0.1"
|
||||
tokio-io = "0.1"
|
||||
|
||||
[dev-dependencies]
|
||||
|
@@ -7,5 +7,7 @@ authors = ["Parity Technologies <admin@parity.io>"]
|
||||
bytes = "0.4"
|
||||
futures = { version = "0.1" }
|
||||
smallvec = "0.5"
|
||||
tokio-core = "0.1"
|
||||
tokio-io = "0.1"
|
||||
|
||||
[dev-dependencies]
|
||||
tokio-core = "0.1"
|
||||
|
@@ -121,7 +121,6 @@
|
||||
extern crate bytes;
|
||||
extern crate futures;
|
||||
extern crate smallvec;
|
||||
extern crate tokio_core;
|
||||
extern crate tokio_io;
|
||||
|
||||
mod dialer_select;
|
||||
|
@@ -157,12 +157,13 @@ impl<R> Stream for Dialer<R>
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
extern crate tokio_core;
|
||||
use bytes::Bytes;
|
||||
use futures::{Sink, Stream};
|
||||
use futures::Future;
|
||||
use protocol::{Dialer, DialerToListenerMessage, MultistreamSelectError};
|
||||
use tokio_core::net::{TcpListener, TcpStream};
|
||||
use tokio_core::reactor::Core;
|
||||
use self::tokio_core::net::{TcpListener, TcpStream};
|
||||
use self::tokio_core::reactor::Core;
|
||||
|
||||
#[test]
|
||||
fn wrong_proto_name() {
|
||||
|
@@ -158,12 +158,13 @@ impl<R> Stream for Listener<R>
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
extern crate tokio_core;
|
||||
use bytes::Bytes;
|
||||
use futures::{Sink, Stream};
|
||||
use futures::Future;
|
||||
use protocol::{Dialer, Listener, ListenerToDialerMessage, MultistreamSelectError};
|
||||
use tokio_core::net::{TcpListener, TcpStream};
|
||||
use tokio_core::reactor::Core;
|
||||
use self::tokio_core::net::{TcpListener, TcpStream};
|
||||
use self::tokio_core::reactor::Core;
|
||||
|
||||
#[test]
|
||||
fn wrong_proto_name() {
|
||||
|
@@ -22,6 +22,8 @@
|
||||
|
||||
#![cfg(test)]
|
||||
|
||||
extern crate tokio_core;
|
||||
|
||||
use {listener_select_proto, dialer_select_proto};
|
||||
use ProtocolChoiceError;
|
||||
use bytes::Bytes;
|
||||
@@ -29,9 +31,9 @@ use dialer_select::{dialer_select_proto_parallel, dialer_select_proto_serial};
|
||||
use futures::{Sink, Stream};
|
||||
use futures::Future;
|
||||
use protocol::{Dialer, Listener, DialerToListenerMessage, ListenerToDialerMessage};
|
||||
use tokio_core::net::TcpListener;
|
||||
use tokio_core::net::TcpStream;
|
||||
use tokio_core::reactor::Core;
|
||||
use self::tokio_core::net::TcpListener;
|
||||
use self::tokio_core::net::TcpStream;
|
||||
use self::tokio_core::reactor::Core;
|
||||
|
||||
#[test]
|
||||
fn negotiate_with_self_succeeds() {
|
||||
|
Reference in New Issue
Block a user