mirror of
https://github.com/tokio-rs/tokio.git
synced 2026-09-08 00:00:13 +02:00
chore: change default lint level to warning and deny warnings in CI (#1416)
This commit is contained in:
@@ -3,6 +3,7 @@ pr: ["master", "std-future"]
|
|||||||
|
|
||||||
variables:
|
variables:
|
||||||
nightly: nightly-2019-07-17
|
nightly: nightly-2019-07-17
|
||||||
|
RUSTFLAGS: -Dwarnings
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
# Check formatting
|
# Check formatting
|
||||||
|
|||||||
+1
-1
@@ -12,5 +12,5 @@ jobs:
|
|||||||
cargo clippy --version
|
cargo clippy --version
|
||||||
displayName: Install clippy
|
displayName: Install clippy
|
||||||
- script: |
|
- script: |
|
||||||
cargo clippy --all --all-features -- -D warnings -A clippy::mutex-atomic
|
cargo clippy --all --all-features -- -A clippy::mutex-atomic
|
||||||
displayName: cargo clippy --all
|
displayName: cargo clippy --all
|
||||||
|
|||||||
@@ -1,11 +1,10 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-buf/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-buf/0.2.0-alpha.1")]
|
||||||
#![deny(
|
#![warn(
|
||||||
missing_docs,
|
missing_docs,
|
||||||
missing_debug_implementations,
|
missing_debug_implementations,
|
||||||
unreachable_pub,
|
unreachable_pub,
|
||||||
rust_2018_idioms
|
rust_2018_idioms
|
||||||
)]
|
)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
|
|
||||||
//! Asynchronous stream of bytes.
|
//! Asynchronous stream of bytes.
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-codec/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-codec/0.2.0-alpha.1")]
|
||||||
#![deny(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
#![warn(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
|
|
||||||
//! Utilities for encoding and decoding frames.
|
//! Utilities for encoding and decoding frames.
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use bytes::{BufMut, Bytes, BytesMut};
|
use bytes::{BufMut, Bytes, BytesMut};
|
||||||
use tokio_codec::{BytesCodec, Decoder, Encoder, LinesCodec};
|
use tokio_codec::{BytesCodec, Decoder, Encoder, LinesCodec};
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use tokio::prelude::*;
|
use tokio::prelude::*;
|
||||||
use tokio_codec::{Decoder, Encoder, Framed, FramedParts};
|
use tokio_codec::{Decoder, Encoder, Framed, FramedParts};
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use tokio::prelude::*;
|
use tokio::prelude::*;
|
||||||
use tokio_codec::{Decoder, FramedRead};
|
use tokio_codec::{Decoder, FramedRead};
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use tokio_codec::{Encoder, FramedWrite};
|
use tokio_codec::{Encoder, FramedWrite};
|
||||||
use tokio_io::AsyncWrite;
|
use tokio_io::AsyncWrite;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use tokio::codec::*;
|
use tokio::codec::*;
|
||||||
use tokio::io::{AsyncRead, AsyncWrite};
|
use tokio::io::{AsyncRead, AsyncWrite};
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-current-thread/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-current-thread/0.2.0-alpha.1")]
|
||||||
#![deny(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
#![warn(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
|
|
||||||
//! A single-threaded executor which executes tasks on the same thread from which
|
//! A single-threaded executor which executes tasks on the same thread from which
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use std::any::Any;
|
use std::any::Any;
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-executor/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-executor/0.2.0-alpha.1")]
|
||||||
#![deny(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
#![warn(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
|
|
||||||
//! Task execution related traits and utilities.
|
//! Task execution related traits and utilities.
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(await_macro, async_await)]
|
#![feature(await_macro, async_await)]
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(await_macro, async_await)]
|
#![feature(await_macro, async_await)]
|
||||||
|
|
||||||
use tokio_executor::{self, DefaultExecutor};
|
use tokio_executor::{self, DefaultExecutor};
|
||||||
|
|||||||
@@ -1,5 +1,4 @@
|
|||||||
//! Echo everything received on STDIN to STDOUT.
|
//! Echo everything received on STDIN to STDOUT.
|
||||||
#![deny(deprecated, warnings)]
|
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_codec::{FramedRead, FramedWrite, LinesCodec};
|
use tokio_codec::{FramedRead, FramedWrite, LinesCodec};
|
||||||
|
|||||||
+1
-2
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-fs/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-fs/0.2.0-alpha.1")]
|
||||||
#![deny(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
#![warn(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use futures_util::future;
|
use futures_util::future;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use rand::{distributions, thread_rng, Rng};
|
use rand::{distributions, thread_rng, Rng};
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use std::fs;
|
use std::fs;
|
||||||
|
|||||||
+1
-2
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-io/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-io/0.2.0-alpha.1")]
|
||||||
#![deny(missing_debug_implementations, missing_docs, rust_2018_idioms)]
|
#![warn(missing_debug_implementations, missing_docs, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
|
|
||||||
//! Core I/O traits and combinators when working with Tokio.
|
//! Core I/O traits and combinators when working with Tokio.
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_io::{AsyncRead, AsyncReadExt};
|
use tokio_io::{AsyncRead, AsyncReadExt};
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use futures_util::StreamExt;
|
use futures_util::StreamExt;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_io::{AsyncRead, AsyncReadExt};
|
use tokio_io::{AsyncRead, AsyncReadExt};
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_io::AsyncReadExt;
|
use tokio_io::AsyncReadExt;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use std::io::Cursor;
|
use std::io::Cursor;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_io::AsyncReadExt;
|
use tokio_io::AsyncReadExt;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_io::AsyncReadExt;
|
use tokio_io::AsyncReadExt;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_io::AsyncBufReadExt;
|
use tokio_io::AsyncBufReadExt;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_io::{AsyncWrite, AsyncWriteExt};
|
use tokio_io::{AsyncWrite, AsyncWriteExt};
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_io::{AsyncWrite, AsyncWriteExt};
|
use tokio_io::{AsyncWrite, AsyncWriteExt};
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-macros/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-macros/0.2.0-alpha.1")]
|
||||||
#![deny(missing_debug_implementations, unreachable_pub, rust_2018_idioms)]
|
#![warn(missing_debug_implementations, unreachable_pub, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
|
|
||||||
//! Macros for use with Tokio
|
//! Macros for use with Tokio
|
||||||
|
|||||||
@@ -118,8 +118,7 @@
|
|||||||
//! be regained with the `Child::forget` method.
|
//! be regained with the `Child::forget` method.
|
||||||
|
|
||||||
#![doc(html_root_url = "https://docs.rs/tokio-process/0.3.0")]
|
#![doc(html_root_url = "https://docs.rs/tokio-process/0.3.0")]
|
||||||
#![deny(missing_debug_implementations, missing_docs, rust_2018_idioms)]
|
#![warn(missing_debug_implementations, missing_docs, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![cfg(unix)]
|
#![cfg(unix)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use futures_util::future::FutureExt;
|
use futures_util::future::FutureExt;
|
||||||
use futures_util::stream::FuturesOrdered;
|
use futures_util::stream::FuturesOrdered;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_process::CommandExt;
|
use tokio_process::CommandExt;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
#[macro_use]
|
#[macro_use]
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use futures_util::future;
|
use futures_util::future;
|
||||||
use futures_util::future::FutureExt;
|
use futures_util::future::FutureExt;
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![feature(test)]
|
#![feature(test)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
/*
|
/*
|
||||||
extern crate test;
|
extern crate test;
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-reactor/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-reactor/0.2.0-alpha.1")]
|
||||||
#![deny(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
#![warn(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
|
|
||||||
//! Event loop that drives Tokio I/O resources.
|
//! Event loop that drives Tokio I/O resources.
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use futures_util::stream::StreamExt;
|
use futures_util::stream::StreamExt;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
//! A small example of how to listen for two signals at the same time
|
//! A small example of how to listen for two signals at the same time
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
// A trick to not fail build on non-unix platforms when using unix-specific features.
|
// A trick to not fail build on non-unix platforms when using unix-specific features.
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-signal/0.3.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-signal/0.3.0-alpha.1")]
|
||||||
#![deny(missing_debug_implementations, missing_docs, rust_2018_idioms)]
|
#![warn(missing_debug_implementations, missing_docs, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![cfg_attr(test, feature(async_await))]
|
#![cfg_attr(test, feature(async_await))]
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![cfg(unix)]
|
#![cfg(unix)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use libc;
|
use libc;
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![cfg(unix)]
|
#![cfg(unix)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use libc;
|
use libc;
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![cfg(unix)]
|
#![cfg(unix)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use libc;
|
use libc;
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![cfg(unix)]
|
#![cfg(unix)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
pub mod support;
|
pub mod support;
|
||||||
use crate::support::*;
|
use crate::support::*;
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![cfg(unix)]
|
#![cfg(unix)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
pub mod support;
|
pub mod support;
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![cfg(unix)]
|
#![cfg(unix)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
pub mod support;
|
pub mod support;
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![cfg(unix)]
|
#![cfg(unix)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use futures_util::future::FutureExt;
|
use futures_util::future::FutureExt;
|
||||||
use libc::{c_int, getpid, kill};
|
use libc::{c_int, getpid, kill};
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![cfg(unix)]
|
#![cfg(unix)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
pub mod support;
|
pub mod support;
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![feature(test)]
|
#![feature(test)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
extern crate test;
|
extern crate test;
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![feature(test)]
|
#![feature(test)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
extern crate test;
|
extern crate test;
|
||||||
|
|
||||||
|
|||||||
@@ -1,11 +1,10 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-sync/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-sync/0.2.0-alpha.1")]
|
||||||
#![deny(
|
#![warn(
|
||||||
missing_debug_implementations,
|
missing_debug_implementations,
|
||||||
missing_docs,
|
missing_docs,
|
||||||
unreachable_pub,
|
unreachable_pub,
|
||||||
rust_2018_idioms
|
rust_2018_idioms
|
||||||
)]
|
)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
|
|||||||
@@ -60,14 +60,16 @@ use crate::task::AtomicWaker;
|
|||||||
use core::task::Poll::{Pending, Ready};
|
use core::task::Poll::{Pending, Ready};
|
||||||
use core::task::{Context, Poll};
|
use core::task::{Context, Poll};
|
||||||
use fnv::FnvHashMap;
|
use fnv::FnvHashMap;
|
||||||
use futures_core::ready;
|
|
||||||
use futures_util::future::poll_fn;
|
use futures_util::future::poll_fn;
|
||||||
use futures_util::pin_mut;
|
|
||||||
use std::ops;
|
use std::ops;
|
||||||
use std::sync::atomic::AtomicUsize;
|
use std::sync::atomic::AtomicUsize;
|
||||||
use std::sync::atomic::Ordering::SeqCst;
|
use std::sync::atomic::Ordering::SeqCst;
|
||||||
use std::sync::{Arc, Mutex, RwLock, RwLockReadGuard, Weak};
|
use std::sync::{Arc, Mutex, RwLock, RwLockReadGuard, Weak};
|
||||||
|
|
||||||
|
#[cfg(feature = "async-traits")]
|
||||||
|
use futures_core::ready;
|
||||||
|
#[cfg(feature = "async-traits")]
|
||||||
|
use futures_util::pin_mut;
|
||||||
#[cfg(feature = "async-traits")]
|
#[cfg(feature = "async-traits")]
|
||||||
use std::pin::Pin;
|
use std::pin::Pin;
|
||||||
|
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use std::task::Waker;
|
use std::task::Waker;
|
||||||
use tokio_sync::AtomicWaker;
|
use tokio_sync::AtomicWaker;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
fn is_error<T: ::std::error::Error + Send + Sync>() {}
|
fn is_error<T: ::std::error::Error + Send + Sync>() {}
|
||||||
|
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
#[macro_use]
|
#[macro_use]
|
||||||
extern crate loom;
|
extern crate loom;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
#[macro_use]
|
#[macro_use]
|
||||||
extern crate loom;
|
extern crate loom;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
#[macro_use]
|
#[macro_use]
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
#[path = "../src/oneshot.rs"]
|
#[path = "../src/oneshot.rs"]
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
#[macro_use]
|
#[macro_use]
|
||||||
extern crate loom;
|
extern crate loom;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use tokio_sync::Lock;
|
use tokio_sync::Lock;
|
||||||
use tokio_test::task::spawn;
|
use tokio_test::task::spawn;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_sync::mpsc;
|
use tokio_sync::mpsc;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_sync::oneshot;
|
use tokio_sync::oneshot;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use tokio_sync::semaphore::{Permit, Semaphore};
|
use tokio_sync::semaphore::{Permit, Semaphore};
|
||||||
use tokio_test::task::MockTask;
|
use tokio_test::task::MockTask;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use tokio_sync::watch;
|
use tokio_sync::watch;
|
||||||
use tokio_test::task::spawn;
|
use tokio_test::task::spawn;
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-tcp/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-tcp/0.2.0-alpha.1")]
|
||||||
#![deny(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
#![warn(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use tokio::net::{TcpListener, TcpStream};
|
use tokio::net::{TcpListener, TcpStream};
|
||||||
use tokio::prelude::*;
|
use tokio::prelude::*;
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use tokio::net::{TcpListener, TcpStream};
|
use tokio::net::{TcpListener, TcpStream};
|
||||||
use tokio::sync::oneshot;
|
use tokio::sync::oneshot;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio::net::{TcpListener, TcpStream};
|
use tokio::net::{TcpListener, TcpStream};
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use std::thread;
|
use std::thread;
|
||||||
|
|||||||
@@ -1,11 +1,10 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-test/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-test/0.2.0-alpha.1")]
|
||||||
#![deny(
|
#![warn(
|
||||||
missing_docs,
|
missing_docs,
|
||||||
missing_debug_implementations,
|
missing_debug_implementations,
|
||||||
unreachable_pub,
|
unreachable_pub,
|
||||||
rust_2018_idioms
|
rust_2018_idioms
|
||||||
)]
|
)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
|
|
||||||
//! Tokio and Futures based testing utilites
|
//! Tokio and Futures based testing utilites
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![cfg(feature = "broken")]
|
#![cfg(feature = "broken")]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use futures::Future;
|
use futures::Future;
|
||||||
use std::time::{Duration, Instant};
|
use std::time::{Duration, Instant};
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio::io::{AsyncReadExt, AsyncWriteExt};
|
use tokio::io::{AsyncReadExt, AsyncWriteExt};
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![cfg(feature = "broken")]
|
#![cfg(feature = "broken")]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use futures::{future, Async, Future, Poll};
|
use futures::{future, Async, Future, Poll};
|
||||||
use tokio_macros::{assert_not_ready, assert_ready, assert_ready_eq};
|
use tokio_macros::{assert_not_ready, assert_ready, assert_ready_eq};
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![feature(test)]
|
#![feature(test)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
extern crate test;
|
extern crate test;
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![feature(test)]
|
#![feature(test)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
extern crate test;
|
extern crate test;
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![feature(test)]
|
#![feature(test)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
extern crate test;
|
extern crate test;
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-threadpool/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-threadpool/0.2.0-alpha.1")]
|
||||||
#![deny(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
#![warn(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
|
|
||||||
//! A work-stealing based thread pool for executing futures.
|
//! A work-stealing based thread pool for executing futures.
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(/* warnings, */ rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_test::*;
|
use tokio_test::*;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_sync::{mpsc, oneshot};
|
use tokio_sync::{mpsc, oneshot};
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_executor::park::{Park, Unpark};
|
use tokio_executor::park::{Park, Unpark};
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-timer/0.3.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-timer/0.3.0-alpha.1")]
|
||||||
#![deny(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
#![warn(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use std::time::Instant;
|
use std::time::Instant;
|
||||||
use tokio_timer::clock;
|
use tokio_timer::clock;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_test::task::MockTask;
|
use tokio_test::task::MockTask;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_current_thread::CurrentThread;
|
use tokio_current_thread::CurrentThread;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_test::task::MockTask;
|
use tokio_test::task::MockTask;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use tokio_test::task::MockTask;
|
use tokio_test::task::MockTask;
|
||||||
use tokio_test::{assert_ok, assert_pending, assert_ready, clock};
|
use tokio_test::{assert_ok, assert_pending, assert_ready, clock};
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![cfg(feature = "async-traits")]
|
#![cfg(feature = "async-traits")]
|
||||||
|
|
||||||
use tokio_sync::mpsc;
|
use tokio_sync::mpsc;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use tokio_sync::oneshot;
|
use tokio_sync::oneshot;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
// #![deny(warnings, rust_2018_idioms)]
|
// #![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use native_tls::TlsConnector;
|
use native_tls::TlsConnector;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
// A tiny async TLS echo server with Tokio
|
// A tiny async TLS echo server with Tokio
|
||||||
use native_tls;
|
use native_tls;
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-tls/0.3.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-tls/0.3.0-alpha.1")]
|
||||||
#![deny(rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use cfg_if::cfg_if;
|
use cfg_if::cfg_if;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use cfg_if::cfg_if;
|
use cfg_if::cfg_if;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
use cfg_if::cfg_if;
|
use cfg_if::cfg_if;
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
#![doc(html_root_url = "https://docs.rs/tokio-tcp/0.2.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-tcp/0.2.0-alpha.1")]
|
||||||
#![deny(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
#![warn(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use tokio_udp::UdpSocket;
|
use tokio_udp::UdpSocket;
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
#![cfg(unix)]
|
#![cfg(unix)]
|
||||||
#![doc(html_root_url = "https://docs.rs/tokio-uds/0.3.0-alpha.1")]
|
#![doc(html_root_url = "https://docs.rs/tokio-uds/0.3.0-alpha.1")]
|
||||||
#![deny(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
#![warn(missing_docs, missing_debug_implementations, rust_2018_idioms)]
|
||||||
#![cfg_attr(test, deny(warnings))]
|
|
||||||
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
#![doc(test(no_crate_inject, attr(deny(rust_2018_idioms))))]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
#![cfg(unix)]
|
#![cfg(unix)]
|
||||||
#![feature(async_await)]
|
#![feature(async_await)]
|
||||||
#![deny(warnings, rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
|
|
||||||
use std::io;
|
use std::io;
|
||||||
use tempfile;
|
use tempfile;
|
||||||
|
|||||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user