Skip to content

Commit 78790e7

Browse files
committed
Fix warning, use version of released tokio
1 parent cd4bdd2 commit 78790e7

File tree

2 files changed

+2
-5
lines changed

2 files changed

+2
-5
lines changed

Cargo.toml

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ log = "0.4"
2727
mio = "0.6"
2828
pin-project = "0.4"
2929
pcap-sys = "0.1"
30-
tokio = { version = "0.2", features = ["blocking", "io-driver", "rt-threaded", "time"] }
30+
tokio = { version = "0.2.21", features = ["blocking", "io-driver", "rt-threaded", "time"] }
3131

3232
[dev-dependencies]
3333
rand = "0.3"
@@ -42,6 +42,3 @@ path = "src/lib.rs"
4242
path = "benches/bench_capture.rs"
4343
name = "bench_capture"
4444
harness = false
45-
46-
[patch.crates-io]
47-
tokio = { git = "https://github.com/dbcfd/tokio.git", branch = "poll-evented-error-2413" }

src/bridge_stream.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ impl<E: Fail + Sync + Send, T: Stream<Item = StreamItem<E>> + Sized + Unpin> Bri
120120
max_buffer_time: Duration,
121121
min_states_needed: usize,
122122
) -> Result<BridgeStream<E, T>, Error> {
123-
let mut poll_queue = FuturesUnordered::new();
123+
let poll_queue = FuturesUnordered::new();
124124
let mut stream_states = VecDeque::with_capacity(streams.len());
125125
for (idx, stream) in streams.into_iter().enumerate() {
126126
let new_state = BridgeStreamState {

0 commit comments

Comments
 (0)