mirror of
https://github.com/tokio-rs/tokio.git
synced 2026-09-08 00:00:13 +02:00
stream: fix disabled tests (#4441)
This commit is contained in:
@@ -1,10 +1,10 @@
|
|||||||
#![cfg(feature = "full")]
|
#![cfg(all(feature = "time", feature = "sync", feature = "io-util"))]
|
||||||
|
|
||||||
use tokio::time::{self, sleep, Duration};
|
use tokio::time::{self, sleep, Duration};
|
||||||
use tokio_stream::{self, StreamExt};
|
use tokio_stream::{self, StreamExt};
|
||||||
use tokio_test::*;
|
use tokio_test::*;
|
||||||
|
|
||||||
use futures::StreamExt as _;
|
use futures::stream;
|
||||||
|
|
||||||
async fn maybe_sleep(idx: i32) -> i32 {
|
async fn maybe_sleep(idx: i32) -> i32 {
|
||||||
if idx % 2 == 0 {
|
if idx % 2 == 0 {
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#![warn(rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![cfg(feature = "full")]
|
#![cfg(all(feature = "time", feature = "sync", feature = "io-util"))]
|
||||||
|
|
||||||
use tokio::time;
|
use tokio::time;
|
||||||
use tokio_stream::StreamExt;
|
use tokio_stream::StreamExt;
|
||||||
|
|||||||
Reference in New Issue
Block a user