[INFO] crate tokio-mqttc 0.0.2 is already in cache [INFO] extracting crate tokio-mqttc 0.0.2 into work/ex/pr-60162/sources/master#a850a426491e14186af2250549bf41256b5938d2/reg/tokio-mqttc/0.0.2 [INFO] extracting crate tokio-mqttc 0.0.2 into work/ex/pr-60162/sources/try#06a150c7d11500b41499224f165e9de1de096768/reg/tokio-mqttc/0.0.2 [INFO] validating manifest of tokio-mqttc-0.0.2 on toolchain master#a850a426491e14186af2250549bf41256b5938d2 [INFO] running `"/mnt/crater-raid/crater/work/local/cargo-home/bin/cargo" "+a850a426491e14186af2250549bf41256b5938d2-alt" "read-manifest" "--manifest-path" "Cargo.toml"` [INFO] validating manifest of tokio-mqttc-0.0.2 on toolchain try#06a150c7d11500b41499224f165e9de1de096768 [INFO] running `"/mnt/crater-raid/crater/work/local/cargo-home/bin/cargo" "+06a150c7d11500b41499224f165e9de1de096768-alt" "read-manifest" "--manifest-path" "Cargo.toml"` [INFO] started frobbing tokio-mqttc-0.0.2 [INFO] finished frobbing tokio-mqttc-0.0.2 [INFO] frobbed toml for tokio-mqttc-0.0.2 written to work/ex/pr-60162/sources/master#a850a426491e14186af2250549bf41256b5938d2/reg/tokio-mqttc/0.0.2/Cargo.toml [INFO] started frobbing tokio-mqttc-0.0.2 [INFO] finished frobbing tokio-mqttc-0.0.2 [INFO] frobbed toml for tokio-mqttc-0.0.2 written to work/ex/pr-60162/sources/try#06a150c7d11500b41499224f165e9de1de096768/reg/tokio-mqttc/0.0.2/Cargo.toml [INFO] running `"/mnt/crater-raid/crater/work/local/cargo-home/bin/cargo" "+a850a426491e14186af2250549bf41256b5938d2-alt" "generate-lockfile" "--manifest-path" "Cargo.toml" "-Zno-index-update"` [INFO] running `"/mnt/crater-raid/crater/work/local/cargo-home/bin/cargo" "+06a150c7d11500b41499224f165e9de1de096768-alt" "generate-lockfile" "--manifest-path" "Cargo.toml" "-Zno-index-update"` [INFO] running `"/mnt/crater-raid/crater/work/local/cargo-home/bin/cargo" "+a850a426491e14186af2250549bf41256b5938d2-alt" "fetch" "--locked" "--manifest-path" "Cargo.toml"` [INFO] running `"/mnt/crater-raid/crater/work/local/cargo-home/bin/cargo" "+06a150c7d11500b41499224f165e9de1de096768-alt" "fetch" "--locked" "--manifest-path" "Cargo.toml"` [INFO] checking tokio-mqttc-0.0.2 against master#a850a426491e14186af2250549bf41256b5938d2 for pr-60162 [INFO] running `"docker" "create" "-v" "/mnt/crater-raid/crater/work/local/target-dirs/pr-60162/worker-4/master#a850a426491e14186af2250549bf41256b5938d2:/opt/crater/target:rw,Z" "-v" "/mnt/crater-raid/crater/work/ex/pr-60162/sources/master#a850a426491e14186af2250549bf41256b5938d2/reg/tokio-mqttc/0.0.2:/opt/crater/workdir:ro,Z" "-v" "/mnt/crater-raid/crater/work/local/cargo-home:/opt/crater/cargo-home:ro,Z" "-v" "/mnt/crater-raid/crater/work/local/rustup-home:/opt/crater/rustup-home:ro,Z" "-e" "USER_ID=1000" "-e" "SOURCE_DIR=/opt/crater/workdir" "-e" "MAP_USER_ID=1000" "-e" "CARGO_TARGET_DIR=/opt/crater/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/crater/cargo-home" "-e" "RUSTUP_HOME=/opt/crater/rustup-home" "-w" "/opt/crater/workdir" "-m" "1536M" "--network" "none" "rustops/crates-build-env" "/opt/crater/cargo-home/bin/cargo" "+a850a426491e14186af2250549bf41256b5938d2-alt" "check" "--frozen" "--all" "--all-targets"` [INFO] [stdout] 0ce300364d585d56f2e62acacab51a8cdd53ba51a667950b95c496643a2874c3 [INFO] running `"docker" "start" "-a" "0ce300364d585d56f2e62acacab51a8cdd53ba51a667950b95c496643a2874c3"` [INFO] [stderr] Checking futures-mutex v0.1.2 [INFO] [stderr] Checking touch v0.0.1 [INFO] [stderr] Checking nom-test-helpers v2.0.0 [INFO] [stderr] Checking linked-hash-map v0.5.2 [INFO] [stderr] Checking tokio-mqttc v0.0.2 (/opt/crater/workdir) [INFO] [stderr] warning: unused import: `Error` [INFO] [stderr] --> src/proto/types.rs:4:14 [INFO] [stderr] | [INFO] [stderr] 4 | use errors::{Error, ErrorKind}; [INFO] [stderr] | ^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: #[warn(unused_imports)] on by default [INFO] [stderr] [INFO] [stderr] warning: unused import: `linked_hash_map::LinkedHashMap` [INFO] [stderr] --> src/proto/types.rs:5:5 [INFO] [stderr] | [INFO] [stderr] 5 | use linked_hash_map::LinkedHashMap; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `IResult`, `be_u16` [INFO] [stderr] --> src/proto/headers.rs:3:11 [INFO] [stderr] | [INFO] [stderr] 3 | use nom::{IResult, be_u16}; [INFO] [stderr] | ^^^^^^^ ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::io` [INFO] [stderr] --> src/proto/mod.rs:8:5 [INFO] [stderr] | [INFO] [stderr] 8 | use std::io; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Entry` [INFO] [stderr] --> src/proto/mod.rs:12:23 [INFO] [stderr] | [INFO] [stderr] 12 | use linked_hash_map::{Entry,LinkedHashMap}; [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Writer` [INFO] [stderr] --> src/proto/mod.rs:13:38 [INFO] [stderr] | [INFO] [stderr] 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `self::headers::*` [INFO] [stderr] --> src/proto/mod.rs:15:5 [INFO] [stderr] | [INFO] [stderr] 15 | use self::headers::*; [INFO] [stderr] | ^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/mqtt_loop.rs:13:5 [INFO] [stderr] | [INFO] [stderr] 13 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `MqttFramedWriter` [INFO] [stderr] --> src/tokio/mqtt_loop.rs:21:13 [INFO] [stderr] | [INFO] [stderr] 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, [INFO] [stderr] | ^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `super::response::ResponseProcessor` [INFO] [stderr] --> src/tokio/mqtt_loop.rs:23:5 [INFO] [stderr] | [INFO] [stderr] 23 | use super::response::ResponseProcessor; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `super::request::RequestProcessor` [INFO] [stderr] --> src/tokio/mqtt_loop.rs:24:5 [INFO] [stderr] | [INFO] [stderr] 24 | use super::request::RequestProcessor; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:1:16 [INFO] [stderr] | [INFO] [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Sink` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:2:28 [INFO] [stderr] | [INFO] [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; [INFO] [stderr] | ^^^^^^^^^ ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:4:5 [INFO] [stderr] | [INFO] [stderr] 4 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:6:5 [INFO] [stderr] | [INFO] [stderr] 6 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:9:25 [INFO] [stderr] | [INFO] [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ErrorKind`, `ResultExt` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:10:29 [INFO] [stderr] | [INFO] [stderr] 10 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `PublishState` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:12:25 [INFO] [stderr] | [INFO] [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; [INFO] [stderr] | ^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/outbound_handlers/publish.rs:1:16 [INFO] [stderr] | [INFO] [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Sink` [INFO] [stderr] --> src/tokio/outbound_handlers/publish.rs:2:28 [INFO] [stderr] | [INFO] [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; [INFO] [stderr] | ^^^^^^^^^ ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/outbound_handlers/publish.rs:4:5 [INFO] [stderr] | [INFO] [stderr] 4 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `PacketType` [INFO] [stderr] --> src/tokio/outbound_handlers/publish.rs:9:25 [INFO] [stderr] | [INFO] [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `OneTimeKey` [INFO] [stderr] --> src/tokio/outbound_handlers/publish.rs:12:13 [INFO] [stderr] | [INFO] [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `BoxFuture` [INFO] [stderr] --> src/tokio/outbound_handlers/mod.rs:8:27 [INFO] [stderr] | [INFO] [stderr] 8 | use tokio::{RequestTuple, BoxFuture}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 [INFO] [stderr] | [INFO] [stderr] 3 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `AsyncSink` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 [INFO] [stderr] | [INFO] [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::unsync::mpsc::UnboundedSender; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 [INFO] [stderr] | [INFO] [stderr] 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] 12 | PacketId, TopicName}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ResultExt`, `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 [INFO] [stderr] | [INFO] [stderr] 14 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 [INFO] [stderr] | [INFO] [stderr] 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; [INFO] [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 [INFO] [stderr] | [INFO] [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `AsyncSink` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use futures::unsync::mpsc::UnboundedSender; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 [INFO] [stderr] | [INFO] [stderr] 8 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 [INFO] [stderr] | [INFO] [stderr] 10 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 [INFO] [stderr] | [INFO] [stderr] 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] 13 | PacketId, TopicName}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ResultExt`, `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 [INFO] [stderr] | [INFO] [stderr] 15 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 [INFO] [stderr] | [INFO] [stderr] 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; [INFO] [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::ops::Deref` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | use std::ops::Deref; [INFO] [stderr] | ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:4:16 [INFO] [stderr] | [INFO] [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Poll` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:15 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:8:5 [INFO] [stderr] | [INFO] [stderr] 8 | use futures::unsync::mpsc::UnboundedSender; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:11:5 [INFO] [stderr] | [INFO] [stderr] 11 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:13:13 [INFO] [stderr] | [INFO] [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] 14 | PacketId, TopicName}; [INFO] [stderr] | ^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:16:21 [INFO] [stderr] | [INFO] [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:17:5 [INFO] [stderr] | [INFO] [stderr] 17 | use errors::proto::ErrorKind as ProtoErrorKind; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:19:25 [INFO] [stderr] | [INFO] [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; [INFO] [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::collections::hash_map::Entry` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:1:5 [INFO] [stderr] | [INFO] [stderr] 1 | use std::collections::hash_map::Entry; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::ops::Deref` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | use std::ops::Deref; [INFO] [stderr] | ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:5:16 [INFO] [stderr] | [INFO] [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:6:28 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^^^^ ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:11:5 [INFO] [stderr] | [INFO] [stderr] 11 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:13:25 [INFO] [stderr] | [INFO] [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:16:21 [INFO] [stderr] | [INFO] [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:19:13 [INFO] [stderr] | [INFO] [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::collections::hash_map::Entry` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:1:5 [INFO] [stderr] | [INFO] [stderr] 1 | use std::collections::hash_map::Entry; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::ops::Deref` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | use std::ops::Deref; [INFO] [stderr] | ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bytes::Bytes` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:4:5 [INFO] [stderr] | [INFO] [stderr] 4 | use bytes::Bytes; [INFO] [stderr] | ^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:5:16 [INFO] [stderr] | [INFO] [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Poll` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:15 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:8:5 [INFO] [stderr] | [INFO] [stderr] 8 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use futures::unsync::mpsc::UnboundedSender; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:10:5 [INFO] [stderr] | [INFO] [stderr] 10 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:12:5 [INFO] [stderr] | [INFO] [stderr] 12 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:14:25 [INFO] [stderr] | [INFO] [stderr] 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] 15 | PacketId, TopicName}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:17:21 [INFO] [stderr] | [INFO] [stderr] 17 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:20:13 [INFO] [stderr] | [INFO] [stderr] 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::collections::hash_map::Entry` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 [INFO] [stderr] | [INFO] [stderr] 1 | use std::collections::hash_map::Entry; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::ops::Deref` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | use std::ops::Deref; [INFO] [stderr] | ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bytes::Bytes` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 [INFO] [stderr] | [INFO] [stderr] 4 | use bytes::Bytes; [INFO] [stderr] | ^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 [INFO] [stderr] | [INFO] [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `AsyncSink` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 [INFO] [stderr] | [INFO] [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] 14 | PacketId, TopicName}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 [INFO] [stderr] | [INFO] [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 [INFO] [stderr] | [INFO] [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::collections::hash_map::Entry` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:1:5 [INFO] [stderr] | [INFO] [stderr] 1 | use std::collections::hash_map::Entry; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::ops::Deref` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | use std::ops::Deref; [INFO] [stderr] | ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:5:16 [INFO] [stderr] | [INFO] [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:28 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^^^^ ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:11:5 [INFO] [stderr] | [INFO] [stderr] 11 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:13:25 [INFO] [stderr] | [INFO] [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:16:21 [INFO] [stderr] | [INFO] [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:19:13 [INFO] [stderr] | [INFO] [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Error` [INFO] [stderr] --> src/proto/types.rs:4:14 [INFO] [stderr] | [INFO] [stderr] 4 | use errors::{Error, ErrorKind}; [INFO] [stderr] | ^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: #[warn(unused_imports)] on by default [INFO] [stderr] [INFO] [stderr] warning: unused import: `linked_hash_map::LinkedHashMap` [INFO] [stderr] --> src/proto/types.rs:5:5 [INFO] [stderr] | [INFO] [stderr] 5 | use linked_hash_map::LinkedHashMap; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `IResult`, `be_u16` [INFO] [stderr] --> src/proto/headers.rs:3:11 [INFO] [stderr] | [INFO] [stderr] 3 | use nom::{IResult, be_u16}; [INFO] [stderr] | ^^^^^^^ ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::io` [INFO] [stderr] --> src/proto/mod.rs:8:5 [INFO] [stderr] | [INFO] [stderr] 8 | use std::io; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Entry` [INFO] [stderr] --> src/proto/mod.rs:12:23 [INFO] [stderr] | [INFO] [stderr] 12 | use linked_hash_map::{Entry,LinkedHashMap}; [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Writer` [INFO] [stderr] --> src/proto/mod.rs:13:38 [INFO] [stderr] | [INFO] [stderr] 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `self::headers::*` [INFO] [stderr] --> src/proto/mod.rs:15:5 [INFO] [stderr] | [INFO] [stderr] 15 | use self::headers::*; [INFO] [stderr] | ^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/mqtt_loop.rs:13:5 [INFO] [stderr] | [INFO] [stderr] 13 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `MqttFramedWriter` [INFO] [stderr] --> src/tokio/mqtt_loop.rs:21:13 [INFO] [stderr] | [INFO] [stderr] 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, [INFO] [stderr] | ^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `super::response::ResponseProcessor` [INFO] [stderr] --> src/tokio/mqtt_loop.rs:23:5 [INFO] [stderr] | [INFO] [stderr] 23 | use super::response::ResponseProcessor; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `super::request::RequestProcessor` [INFO] [stderr] --> src/tokio/mqtt_loop.rs:24:5 [INFO] [stderr] | [INFO] [stderr] 24 | use super::request::RequestProcessor; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:1:16 [INFO] [stderr] | [INFO] [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Sink` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:2:28 [INFO] [stderr] | [INFO] [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; [INFO] [stderr] | ^^^^^^^^^ ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:4:5 [INFO] [stderr] | [INFO] [stderr] 4 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:6:5 [INFO] [stderr] | [INFO] [stderr] 6 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:9:25 [INFO] [stderr] | [INFO] [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ErrorKind`, `ResultExt` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:10:29 [INFO] [stderr] | [INFO] [stderr] 10 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `PublishState` [INFO] [stderr] --> src/tokio/outbound_handlers/ping_request.rs:12:25 [INFO] [stderr] | [INFO] [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; [INFO] [stderr] | ^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/outbound_handlers/publish.rs:1:16 [INFO] [stderr] | [INFO] [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Sink` [INFO] [stderr] --> src/tokio/outbound_handlers/publish.rs:2:28 [INFO] [stderr] | [INFO] [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; [INFO] [stderr] | ^^^^^^^^^ ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/outbound_handlers/publish.rs:4:5 [INFO] [stderr] | [INFO] [stderr] 4 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `PacketType` [INFO] [stderr] --> src/tokio/outbound_handlers/publish.rs:9:25 [INFO] [stderr] | [INFO] [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `OneTimeKey` [INFO] [stderr] --> src/tokio/outbound_handlers/publish.rs:12:13 [INFO] [stderr] | [INFO] [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `BoxFuture` [INFO] [stderr] --> src/tokio/outbound_handlers/mod.rs:8:27 [INFO] [stderr] | [INFO] [stderr] 8 | use tokio::{RequestTuple, BoxFuture}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 [INFO] [stderr] | [INFO] [stderr] 3 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `AsyncSink` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 [INFO] [stderr] | [INFO] [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::unsync::mpsc::UnboundedSender; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 [INFO] [stderr] | [INFO] [stderr] 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] 12 | PacketId, TopicName}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ResultExt`, `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 [INFO] [stderr] | [INFO] [stderr] 14 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 [INFO] [stderr] | [INFO] [stderr] 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; [INFO] [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 [INFO] [stderr] | [INFO] [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `AsyncSink` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use futures::unsync::mpsc::UnboundedSender; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 [INFO] [stderr] | [INFO] [stderr] 8 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 [INFO] [stderr] | [INFO] [stderr] 10 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 [INFO] [stderr] | [INFO] [stderr] 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] 13 | PacketId, TopicName}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ResultExt`, `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 [INFO] [stderr] | [INFO] [stderr] 15 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 [INFO] [stderr] | [INFO] [stderr] 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; [INFO] [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::ops::Deref` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | use std::ops::Deref; [INFO] [stderr] | ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:4:16 [INFO] [stderr] | [INFO] [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Poll` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:15 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:8:5 [INFO] [stderr] | [INFO] [stderr] 8 | use futures::unsync::mpsc::UnboundedSender; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:11:5 [INFO] [stderr] | [INFO] [stderr] 11 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:13:13 [INFO] [stderr] | [INFO] [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] 14 | PacketId, TopicName}; [INFO] [stderr] | ^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:16:21 [INFO] [stderr] | [INFO] [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:17:5 [INFO] [stderr] | [INFO] [stderr] 17 | use errors::proto::ErrorKind as ProtoErrorKind; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:19:25 [INFO] [stderr] | [INFO] [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; [INFO] [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::collections::hash_map::Entry` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:1:5 [INFO] [stderr] | [INFO] [stderr] 1 | use std::collections::hash_map::Entry; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::ops::Deref` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | use std::ops::Deref; [INFO] [stderr] | ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:5:16 [INFO] [stderr] | [INFO] [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:6:28 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^^^^ ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:11:5 [INFO] [stderr] | [INFO] [stderr] 11 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:13:25 [INFO] [stderr] | [INFO] [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:16:21 [INFO] [stderr] | [INFO] [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:19:13 [INFO] [stderr] | [INFO] [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::collections::hash_map::Entry` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:1:5 [INFO] [stderr] | [INFO] [stderr] 1 | use std::collections::hash_map::Entry; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::ops::Deref` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | use std::ops::Deref; [INFO] [stderr] | ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bytes::Bytes` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:4:5 [INFO] [stderr] | [INFO] [stderr] 4 | use bytes::Bytes; [INFO] [stderr] | ^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:5:16 [INFO] [stderr] | [INFO] [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Poll` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:15 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:8:5 [INFO] [stderr] | [INFO] [stderr] 8 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use futures::unsync::mpsc::UnboundedSender; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:10:5 [INFO] [stderr] | [INFO] [stderr] 10 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:12:5 [INFO] [stderr] | [INFO] [stderr] 12 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:14:25 [INFO] [stderr] | [INFO] [stderr] 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] 15 | PacketId, TopicName}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:17:21 [INFO] [stderr] | [INFO] [stderr] 17 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:20:13 [INFO] [stderr] | [INFO] [stderr] 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::collections::hash_map::Entry` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 [INFO] [stderr] | [INFO] [stderr] 1 | use std::collections::hash_map::Entry; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::ops::Deref` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | use std::ops::Deref; [INFO] [stderr] | ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bytes::Bytes` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 [INFO] [stderr] | [INFO] [stderr] 4 | use bytes::Bytes; [INFO] [stderr] | ^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 [INFO] [stderr] | [INFO] [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `AsyncSink` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 [INFO] [stderr] | [INFO] [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] 14 | PacketId, TopicName}; [INFO] [stderr] | ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 [INFO] [stderr] | [INFO] [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 [INFO] [stderr] | [INFO] [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::collections::hash_map::Entry` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:1:5 [INFO] [stderr] | [INFO] [stderr] 1 | use std::collections::hash_map::Entry; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `std::ops::Deref` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | use std::ops::Deref; [INFO] [stderr] | ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:5:16 [INFO] [stderr] | [INFO] [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; [INFO] [stderr] | ^^^^^^^^^ ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `AsyncSink`, `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:28 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^^^^ ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `futures::sync::mpsc::unbounded` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:7:5 [INFO] [stderr] | [INFO] [stderr] 7 | use futures::sync::mpsc::unbounded; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `take::Take` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:9:5 [INFO] [stderr] | [INFO] [stderr] 9 | use take::Take; [INFO] [stderr] | ^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `bincode` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:11:5 [INFO] [stderr] | [INFO] [stderr] 11 | use bincode; [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:13:25 [INFO] [stderr] | [INFO] [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:16:21 [INFO] [stderr] | [INFO] [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; [INFO] [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:19:13 [INFO] [stderr] | [INFO] [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, [INFO] [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::BoxFuture': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/types.rs:3:5 [INFO] [stderr] | [INFO] [stderr] 3 | use futures::future::BoxFuture; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: #[warn(deprecated)] on by default [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::stream::BoxStream': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/types.rs:5:5 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::stream::BoxStream; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::BoxFuture': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/types.rs:7:29 [INFO] [stderr] | [INFO] [stderr] 7 | pub type BoxMqttFuture = BoxFuture; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::stream::BoxStream': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/types.rs:9:29 [INFO] [stderr] | [INFO] [stderr] 9 | pub type BoxMqttStream = BoxStream; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec [INFO] [stderr] --> src/tokio/mod.rs:12:5 [INFO] [stderr] | [INFO] [stderr] 12 | use tokio_io::codec::Framed; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec [INFO] [stderr] --> src/tokio/mod.rs:27:40 [INFO] [stderr] | [INFO] [stderr] 27 | type MqttFramedReader = SplitStream>; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec [INFO] [stderr] --> src/tokio/mod.rs:28:38 [INFO] [stderr] | [INFO] [stderr] 28 | type MqttFramedWriter = SplitSink>; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::BoxFuture': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/types.rs:3:5 [INFO] [stderr] | [INFO] [stderr] 3 | use futures::future::BoxFuture; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: #[warn(deprecated)] on by default [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::stream::BoxStream': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/types.rs:5:5 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::stream::BoxStream; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::BoxFuture': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/types.rs:7:29 [INFO] [stderr] | [INFO] [stderr] 7 | pub type BoxMqttFuture = BoxFuture; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::stream::BoxStream': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/types.rs:9:29 [INFO] [stderr] | [INFO] [stderr] 9 | pub type BoxMqttStream = BoxStream; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec [INFO] [stderr] --> src/tokio/mod.rs:12:5 [INFO] [stderr] | [INFO] [stderr] 12 | use tokio_io::codec::Framed; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec [INFO] [stderr] --> src/tokio/mod.rs:27:40 [INFO] [stderr] | [INFO] [stderr] 27 | type MqttFramedReader = SplitStream>; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec [INFO] [stderr] --> src/tokio/mod.rs:28:38 [INFO] [stderr] | [INFO] [stderr] 28 | type MqttFramedWriter = SplitSink>; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le [INFO] [stderr] --> src/proto/types.rs:271:13 [INFO] [stderr] | [INFO] [stderr] 271 | out.put_u16::(self.len() as u16); [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le [INFO] [stderr] --> src/proto/types.rs:271:13 [INFO] [stderr] | [INFO] [stderr] 271 | out.put_u16::(self.len() as u16); [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le [INFO] [stderr] --> src/proto/headers.rs:135:40 [INFO] [stderr] | [INFO] [stderr] 135 | Ok(PacketId(raw.into_buf().get_u16::())) [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le [INFO] [stderr] --> src/proto/headers.rs:140:13 [INFO] [stderr] | [INFO] [stderr] 140 | out.put_u16::(self.0); [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le [INFO] [stderr] --> src/proto/headers.rs:170:41 [INFO] [stderr] | [INFO] [stderr] 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le [INFO] [stderr] --> src/proto/headers.rs:175:13 [INFO] [stderr] | [INFO] [stderr] 175 | out.put_u16::(self.0); [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/client.rs:223:55 [INFO] [stderr] | [INFO] [stderr] 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/client.rs:266:63 [INFO] [stderr] | [INFO] [stderr] 266 | client.request(connect).into_future().map(|_| ()).boxed() [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le [INFO] [stderr] --> src/proto/headers.rs:135:40 [INFO] [stderr] | [INFO] [stderr] 135 | Ok(PacketId(raw.into_buf().get_u16::())) [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le [INFO] [stderr] --> src/proto/headers.rs:140:13 [INFO] [stderr] | [INFO] [stderr] 140 | out.put_u16::(self.0); [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le [INFO] [stderr] --> src/proto/headers.rs:170:41 [INFO] [stderr] | [INFO] [stderr] 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le [INFO] [stderr] --> src/proto/headers.rs:175:13 [INFO] [stderr] | [INFO] [stderr] 175 | out.put_u16::(self.0); [INFO] [stderr] | ^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/client.rs:223:55 [INFO] [stderr] | [INFO] [stderr] 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::sync::mpsc::UnboundedSender::::send': renamed to `unbounded_send` [INFO] [stderr] --> src/tokio/mqtt_loop.rs:54:32 [INFO] [stderr] | [INFO] [stderr] 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { [INFO] [stderr] | ^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/tokio/mqtt_loop.rs:60:47 [INFO] [stderr] | [INFO] [stderr] 60 | Ok((next_state(sender), Ok(rx.boxed()))) [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/client.rs:266:63 [INFO] [stderr] | [INFO] [stderr] 266 | client.request(connect).into_future().map(|_| ()).boxed() [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead [INFO] [stderr] --> src/tokio/mqtt_loop.rs:266:34 [INFO] [stderr] | [INFO] [stderr] 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/tokio/mqtt_loop.rs:317:14 [INFO] [stderr] | [INFO] [stderr] 317 | .boxed() [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/tokio/mqtt_loop.rs:519:42 [INFO] [stderr] | [INFO] [stderr] 519 | .boxed(), [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::sync::mpsc::UnboundedSender::::send': renamed to `unbounded_send` [INFO] [stderr] --> src/tokio/mqtt_loop.rs:54:32 [INFO] [stderr] | [INFO] [stderr] 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { [INFO] [stderr] | ^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/tokio/response.rs:83:40 [INFO] [stderr] | [INFO] [stderr] 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/tokio/mqtt_loop.rs:60:47 [INFO] [stderr] | [INFO] [stderr] 60 | Ok((next_state(sender), Ok(rx.boxed()))) [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead [INFO] [stderr] --> src/tokio/mqtt_loop.rs:266:34 [INFO] [stderr] | [INFO] [stderr] 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/tokio/mqtt_loop.rs:317:14 [INFO] [stderr] | [INFO] [stderr] 317 | .boxed() [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Future::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/tokio/mqtt_loop.rs:519:42 [INFO] [stderr] | [INFO] [stderr] 519 | .boxed(), [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 [INFO] [stderr] | [INFO] [stderr] 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/tokio/response.rs:83:40 [INFO] [stderr] | [INFO] [stderr] 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'futures::Stream::boxed': removed without replacement, recommended to use a local extension trait or function if needed, more details in https://github.com/rust-lang-nursery/futures-rs/issues/228 [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 [INFO] [stderr] | [INFO] [stderr] 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); [INFO] [stderr] | ^^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'std::error::Error::cause': replaced by Error::source, which can support downcasting [INFO] [stderr] --> src/errors.rs:4:1 [INFO] [stderr] | [INFO] [stderr] 4 | / error_chain! { [INFO] [stderr] 5 | | links { [INFO] [stderr] 6 | | Protocol(self::proto::Error, self::proto::ErrorKind); [INFO] [stderr] 7 | | } [INFO] [stderr] ... | [INFO] [stderr] 66 | | } [INFO] [stderr] 67 | | } [INFO] [stderr] | |_^ [INFO] [stderr] | [INFO] [stderr] = note: this warning originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'std::error::Error::cause': replaced by Error::source, which can support downcasting [INFO] [stderr] --> src/errors.rs:4:1 [INFO] [stderr] | [INFO] [stderr] 4 | / error_chain! { [INFO] [stderr] 5 | | links { [INFO] [stderr] 6 | | Protocol(self::proto::Error, self::proto::ErrorKind); [INFO] [stderr] 7 | | } [INFO] [stderr] ... | [INFO] [stderr] 66 | | } [INFO] [stderr] 67 | | } [INFO] [stderr] | |_^ [INFO] [stderr] | [INFO] [stderr] = note: this warning originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) [INFO] [stderr] [INFO] [stderr] warning: unused import: `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 [INFO] [stderr] | [INFO] [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:39 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:53 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:6:53 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:39 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:53 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:53 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 [INFO] [stderr] | [INFO] [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:39 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:53 [INFO] [stderr] | [INFO] [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:6:53 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Sink` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:39 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:53 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:53 [INFO] [stderr] | [INFO] [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: variable does not need to be mutable [INFO] [stderr] --> src/tokio/mqtt_loop.rs:320:31 [INFO] [stderr] | [INFO] [stderr] 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { [INFO] [stderr] | ----^^^ [INFO] [stderr] | | [INFO] [stderr] | help: remove this `mut` [INFO] [stderr] | [INFO] [stderr] = note: #[warn(unused_mut)] on by default [INFO] [stderr] [INFO] [stderr] warning: variable does not need to be mutable [INFO] [stderr] --> src/tokio/mqtt_loop.rs:320:31 [INFO] [stderr] | [INFO] [stderr] 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { [INFO] [stderr] | ----^^^ [INFO] [stderr] | | [INFO] [stderr] | help: remove this `mut` [INFO] [stderr] | [INFO] [stderr] = note: #[warn(unused_mut)] on by default [INFO] [stderr] [INFO] [stderr] warning: unused `std::result::Result` that must be used [INFO] [stderr] --> src/tokio/mqtt_loop.rs:571:17 [INFO] [stderr] | [INFO] [stderr] 571 | self.poll_queues(sourceitem); [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: #[warn(unused_must_use)] on by default [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `std::result::Result` that must be used [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:104:25 [INFO] [stderr] | [INFO] [stderr] 104 | / requester.unbounded_send(LoopRequest::Internal( [INFO] [stderr] 105 | | MqttPacket::pub_ack_packet(*id), [INFO] [stderr] 106 | | )); [INFO] [stderr] | |___________________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `std::result::Result` that must be used [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:128:29 [INFO] [stderr] | [INFO] [stderr] 128 | / requester.unbounded_send( [INFO] [stderr] 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), [INFO] [stderr] 130 | | ); [INFO] [stderr] | |______________________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `futures::sink::Send` that must be used [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 [INFO] [stderr] | [INFO] [stderr] 100 | requester.send(LoopRequest::Internal(rel)); [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: futures do nothing unless polled [INFO] [stderr] [INFO] [stderr] warning: unused `std::result::Result` that must be used [INFO] [stderr] --> src/tokio/mqtt_loop.rs:571:17 [INFO] [stderr] | [INFO] [stderr] 571 | self.poll_queues(sourceitem); [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: #[warn(unused_must_use)] on by default [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `std::result::Result` that must be used [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:104:25 [INFO] [stderr] | [INFO] [stderr] 104 | / requester.unbounded_send(LoopRequest::Internal( [INFO] [stderr] 105 | | MqttPacket::pub_ack_packet(*id), [INFO] [stderr] 106 | | )); [INFO] [stderr] | |___________________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `std::result::Result` that must be used [INFO] [stderr] --> src/tokio/inbound_handlers/publish.rs:128:29 [INFO] [stderr] | [INFO] [stderr] 128 | / requester.unbounded_send( [INFO] [stderr] 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), [INFO] [stderr] 130 | | ); [INFO] [stderr] | |______________________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `futures::sink::Send` that must be used [INFO] [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 [INFO] [stderr] | [INFO] [stderr] 100 | requester.send(LoopRequest::Internal(rel)); [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: futures do nothing unless polled [INFO] [stderr] [INFO] [stderr] warning: unused `#[macro_use]` import [INFO] [stderr] --> examples/client.rs:1:1 [INFO] [stderr] | [INFO] [stderr] 1 | #[macro_use] [INFO] [stderr] | ^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: #[warn(unused_imports)] on by default [INFO] [stderr] [INFO] [stderr] warning: unused import: `tokio_mqttc::persistence::*` [INFO] [stderr] --> examples/client.rs:11:5 [INFO] [stderr] | [INFO] [stderr] 11 | use tokio_mqttc::persistence::*; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `tokio_mqttc::proto::*` [INFO] [stderr] --> examples/client.rs:13:5 [INFO] [stderr] | [INFO] [stderr] 13 | use tokio_mqttc::proto::*; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `tokio_core::reactor::Handle` [INFO] [stderr] --> examples/client.rs:41:5 [INFO] [stderr] | [INFO] [stderr] 41 | use tokio_core::reactor::Handle; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused imports: `Sink`, `future` [INFO] [stderr] --> examples/client.rs:45:15 [INFO] [stderr] | [INFO] [stderr] 45 | use futures::{future, Future, Stream, Sink}; [INFO] [stderr] | ^^^^^^ ^^^^ [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'std::error::Error::cause': replaced by Error::source, which can support downcasting [INFO] [stderr] --> examples/client.rs:17:5 [INFO] [stderr] | [INFO] [stderr] 17 | / error_chain! { [INFO] [stderr] 18 | | types { [INFO] [stderr] 19 | | Error, ErrorKind, ResultExt, Result; [INFO] [stderr] 20 | | } [INFO] [stderr] ... | [INFO] [stderr] 35 | | } [INFO] [stderr] 36 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] | [INFO] [stderr] = note: #[warn(deprecated)] on by default [INFO] [stderr] = note: this warning originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) [INFO] [stderr] [INFO] [stderr] warning: use of deprecated item 'std::error::Error::cause': replaced by Error::source, which can support downcasting [INFO] [stderr] --> examples/client.rs:17:5 [INFO] [stderr] | [INFO] [stderr] 17 | / error_chain! { [INFO] [stderr] 18 | | types { [INFO] [stderr] 19 | | Error, ErrorKind, ResultExt, Result; [INFO] [stderr] 20 | | } [INFO] [stderr] ... | [INFO] [stderr] 35 | | } [INFO] [stderr] 36 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] | [INFO] [stderr] = note: this warning originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) [INFO] [stderr] [INFO] [stderr] warning: unused import: `Stream` [INFO] [stderr] --> examples/client.rs:45:31 [INFO] [stderr] | [INFO] [stderr] 45 | use futures::{future, Future, Stream, Sink}; [INFO] [stderr] | ^^^^^^ [INFO] [stderr] [INFO] [stderr] Finished dev [unoptimized + debuginfo] target(s) in 8.24s [INFO] running `"docker" "inspect" "0ce300364d585d56f2e62acacab51a8cdd53ba51a667950b95c496643a2874c3"` [INFO] running `"docker" "rm" "-f" "0ce300364d585d56f2e62acacab51a8cdd53ba51a667950b95c496643a2874c3"` [INFO] [stdout] 0ce300364d585d56f2e62acacab51a8cdd53ba51a667950b95c496643a2874c3