Nov 30 14:06:35.597 INFO checking tokio-mqttc-0.0.2 against try#32252761328f59ccfadb1bafb8148c685bc830b3 for pr-56323 Nov 30 14:06:35.597 INFO running `"docker" "create" "-v" "/mnt/big/crater/work/local/target-dirs/pr-56323/worker-5/try#32252761328f59ccfadb1bafb8148c685bc830b3:/target:rw,Z" "-v" "/mnt/big/crater/work/local/test-source/worker-5/pr-56323/try#32252761328f59ccfadb1bafb8148c685bc830b3:/source:ro,Z" "-v" "/mnt/big/crater/work/local/cargo-home:/cargo-home:ro,Z" "-v" "/mnt/big/crater/work/local/rustup-home:/rustup-home:ro,Z" "-e" "USER_ID=1000" "-e" "SOURCE_DIR=/source" "-e" "USER_ID=1000" "-e" "CMD=cargo +32252761328f59ccfadb1bafb8148c685bc830b3-alt check --frozen --all --all-targets" "-e" "CARGO_TARGET_DIR=/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/cargo-home" "-e" "RUSTUP_HOME=/rustup-home" "-m" "1536M" "--network" "none" "crater"` Nov 30 14:06:35.777 INFO [stdout] 9c73feb0fbc74c0ec355f2332c7e7b47426cd7afe3de5fe021b4f8f36d5f4911 Nov 30 14:06:35.783 INFO running `"docker" "start" "-a" "9c73feb0fbc74c0ec355f2332c7e7b47426cd7afe3de5fe021b4f8f36d5f4911"` Nov 30 14:06:36.374 INFO [stderr] usermod: no changes Nov 30 14:06:36.557 INFO [stderr] Checking nom v2.2.1 Nov 30 14:06:36.557 INFO [stderr] Checking futures-mutex v0.1.2 Nov 30 14:06:36.557 INFO [stderr] Checking touch v0.0.1 Nov 30 14:06:36.557 INFO [stderr] Checking serde_test v1.0.80 Nov 30 14:06:36.557 INFO [stderr] Checking bincode v0.9.2 Nov 30 14:06:38.871 INFO [stderr] Checking linked-hash-map v0.5.1 Nov 30 14:06:39.247 INFO [stderr] Checking nom-test-helpers v2.0.0 Nov 30 14:06:39.567 INFO [stderr] Checking tokio-mqttc v0.0.2 (/source) Nov 30 14:06:44.344 INFO [stderr] warning: unused import: `Error` Nov 30 14:06:44.344 INFO [stderr] --> src/proto/types.rs:4:14 Nov 30 14:06:44.344 INFO [stderr] | Nov 30 14:06:44.344 INFO [stderr] 4 | use errors::{Error, ErrorKind}; Nov 30 14:06:44.344 INFO [stderr] | ^^^^^ Nov 30 14:06:44.344 INFO [stderr] | Nov 30 14:06:44.344 INFO [stderr] = note: #[warn(unused_imports)] on by default Nov 30 14:06:44.344 INFO [stderr] Nov 30 14:06:44.348 INFO [stderr] warning: unused import: `linked_hash_map::LinkedHashMap` Nov 30 14:06:44.348 INFO [stderr] --> src/proto/types.rs:5:5 Nov 30 14:06:44.348 INFO [stderr] | Nov 30 14:06:44.348 INFO [stderr] 5 | use linked_hash_map::LinkedHashMap; Nov 30 14:06:44.348 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.348 INFO [stderr] Nov 30 14:06:44.364 INFO [stderr] warning: unused imports: `IResult`, `be_u16` Nov 30 14:06:44.364 INFO [stderr] --> src/proto/headers.rs:3:11 Nov 30 14:06:44.364 INFO [stderr] | Nov 30 14:06:44.364 INFO [stderr] 3 | use nom::{IResult, be_u16}; Nov 30 14:06:44.364 INFO [stderr] | ^^^^^^^ ^^^^^^ Nov 30 14:06:44.364 INFO [stderr] Nov 30 14:06:44.365 INFO [stderr] warning: unused import: `std::io` Nov 30 14:06:44.365 INFO [stderr] --> src/proto/mod.rs:8:5 Nov 30 14:06:44.365 INFO [stderr] | Nov 30 14:06:44.365 INFO [stderr] 8 | use std::io; Nov 30 14:06:44.365 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.365 INFO [stderr] Nov 30 14:06:44.365 INFO [stderr] warning: unused import: `Entry` Nov 30 14:06:44.365 INFO [stderr] --> src/proto/mod.rs:12:23 Nov 30 14:06:44.365 INFO [stderr] | Nov 30 14:06:44.365 INFO [stderr] 12 | use linked_hash_map::{Entry,LinkedHashMap}; Nov 30 14:06:44.365 INFO [stderr] | ^^^^^ Nov 30 14:06:44.365 INFO [stderr] Nov 30 14:06:44.365 INFO [stderr] warning: unused import: `Writer` Nov 30 14:06:44.365 INFO [stderr] --> src/proto/mod.rs:13:38 Nov 30 14:06:44.365 INFO [stderr] | Nov 30 14:06:44.365 INFO [stderr] 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Nov 30 14:06:44.365 INFO [stderr] | ^^^^^^ Nov 30 14:06:44.365 INFO [stderr] Nov 30 14:06:44.365 INFO [stderr] warning: unused import: `self::headers::*` Nov 30 14:06:44.365 INFO [stderr] --> src/proto/mod.rs:15:5 Nov 30 14:06:44.365 INFO [stderr] | Nov 30 14:06:44.365 INFO [stderr] 15 | use self::headers::*; Nov 30 14:06:44.365 INFO [stderr] | ^^^^^^^^^^^^^^^^ Nov 30 14:06:44.366 INFO [stderr] Nov 30 14:06:44.368 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.368 INFO [stderr] --> src/tokio/mqtt_loop.rs:13:5 Nov 30 14:06:44.368 INFO [stderr] | Nov 30 14:06:44.368 INFO [stderr] 13 | use take::Take; Nov 30 14:06:44.368 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.368 INFO [stderr] Nov 30 14:06:44.368 INFO [stderr] warning: unused import: `MqttFramedWriter` Nov 30 14:06:44.368 INFO [stderr] --> src/tokio/mqtt_loop.rs:21:13 Nov 30 14:06:44.368 INFO [stderr] | Nov 30 14:06:44.368 INFO [stderr] 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Nov 30 14:06:44.368 INFO [stderr] | ^^^^^^^^^^^^^^^^ Nov 30 14:06:44.368 INFO [stderr] Nov 30 14:06:44.368 INFO [stderr] warning: unused import: `super::response::ResponseProcessor` Nov 30 14:06:44.368 INFO [stderr] --> src/tokio/mqtt_loop.rs:23:5 Nov 30 14:06:44.368 INFO [stderr] | Nov 30 14:06:44.368 INFO [stderr] 23 | use super::response::ResponseProcessor; Nov 30 14:06:44.368 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.368 INFO [stderr] Nov 30 14:06:44.368 INFO [stderr] warning: unused import: `super::request::RequestProcessor` Nov 30 14:06:44.368 INFO [stderr] --> src/tokio/mqtt_loop.rs:24:5 Nov 30 14:06:44.368 INFO [stderr] | Nov 30 14:06:44.368 INFO [stderr] 24 | use super::request::RequestProcessor; Nov 30 14:06:44.368 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.368 INFO [stderr] Nov 30 14:06:44.370 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.370 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:1:16 Nov 30 14:06:44.371 INFO [stderr] | Nov 30 14:06:44.371 INFO [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.371 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.371 INFO [stderr] Nov 30 14:06:44.371 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Nov 30 14:06:44.377 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:2:28 Nov 30 14:06:44.377 INFO [stderr] | Nov 30 14:06:44.377 INFO [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Nov 30 14:06:44.377 INFO [stderr] | ^^^^^^^^^ ^^^^ Nov 30 14:06:44.377 INFO [stderr] Nov 30 14:06:44.377 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.378 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:4:5 Nov 30 14:06:44.379 INFO [stderr] | Nov 30 14:06:44.379 INFO [stderr] 4 | use take::Take; Nov 30 14:06:44.379 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.379 INFO [stderr] Nov 30 14:06:44.379 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.379 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:6:5 Nov 30 14:06:44.380 INFO [stderr] | Nov 30 14:06:44.380 INFO [stderr] 6 | use bincode; Nov 30 14:06:44.380 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.380 INFO [stderr] Nov 30 14:06:44.380 INFO [stderr] warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Nov 30 14:06:44.380 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:9:25 Nov 30 14:06:44.380 INFO [stderr] | Nov 30 14:06:44.380 INFO [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Nov 30 14:06:44.380 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Nov 30 14:06:44.380 INFO [stderr] Nov 30 14:06:44.380 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt` Nov 30 14:06:44.380 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:10:29 Nov 30 14:06:44.380 INFO [stderr] | Nov 30 14:06:44.381 INFO [stderr] 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.381 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.381 INFO [stderr] Nov 30 14:06:44.381 INFO [stderr] warning: unused import: `PublishState` Nov 30 14:06:44.381 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:12:25 Nov 30 14:06:44.382 INFO [stderr] | Nov 30 14:06:44.382 INFO [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Nov 30 14:06:44.382 INFO [stderr] | ^^^^^^^^^^^^ Nov 30 14:06:44.382 INFO [stderr] Nov 30 14:06:44.382 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.382 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:1:16 Nov 30 14:06:44.382 INFO [stderr] | Nov 30 14:06:44.382 INFO [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.382 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.382 INFO [stderr] Nov 30 14:06:44.382 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Nov 30 14:06:44.382 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:2:28 Nov 30 14:06:44.382 INFO [stderr] | Nov 30 14:06:44.383 INFO [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^^^ ^^^^ Nov 30 14:06:44.383 INFO [stderr] Nov 30 14:06:44.383 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.383 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:4:5 Nov 30 14:06:44.383 INFO [stderr] | Nov 30 14:06:44.383 INFO [stderr] 4 | use take::Take; Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.383 INFO [stderr] Nov 30 14:06:44.383 INFO [stderr] warning: unused import: `PacketType` Nov 30 14:06:44.383 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:9:25 Nov 30 14:06:44.383 INFO [stderr] | Nov 30 14:06:44.383 INFO [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.383 INFO [stderr] Nov 30 14:06:44.383 INFO [stderr] warning: unused import: `OneTimeKey` Nov 30 14:06:44.383 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:12:13 Nov 30 14:06:44.383 INFO [stderr] | Nov 30 14:06:44.383 INFO [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.383 INFO [stderr] Nov 30 14:06:44.383 INFO [stderr] warning: unused import: `BoxFuture` Nov 30 14:06:44.383 INFO [stderr] --> src/tokio/outbound_handlers/mod.rs:8:27 Nov 30 14:06:44.383 INFO [stderr] | Nov 30 14:06:44.383 INFO [stderr] 8 | use tokio::{RequestTuple, BoxFuture}; Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.383 INFO [stderr] Nov 30 14:06:44.383 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.383 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Nov 30 14:06:44.383 INFO [stderr] | Nov 30 14:06:44.383 INFO [stderr] 3 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.383 INFO [stderr] Nov 30 14:06:44.383 INFO [stderr] warning: unused import: `AsyncSink` Nov 30 14:06:44.383 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Nov 30 14:06:44.383 INFO [stderr] | Nov 30 14:06:44.383 INFO [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.383 INFO [stderr] Nov 30 14:06:44.383 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Nov 30 14:06:44.383 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Nov 30 14:06:44.383 INFO [stderr] | Nov 30 14:06:44.383 INFO [stderr] 6 | use futures::unsync::mpsc::UnboundedSender; Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.383 INFO [stderr] Nov 30 14:06:44.383 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.383 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Nov 30 14:06:44.383 INFO [stderr] | Nov 30 14:06:44.383 INFO [stderr] 7 | use take::Take; Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.383 INFO [stderr] Nov 30 14:06:44.383 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.383 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Nov 30 14:06:44.383 INFO [stderr] | Nov 30 14:06:44.383 INFO [stderr] 9 | use bincode; Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.383 INFO [stderr] Nov 30 14:06:44.383 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Nov 30 14:06:44.383 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Nov 30 14:06:44.383 INFO [stderr] | Nov 30 14:06:44.383 INFO [stderr] 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.383 INFO [stderr] 12 | PacketId, TopicName}; Nov 30 14:06:44.383 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.383 INFO [stderr] Nov 30 14:06:44.383 INFO [stderr] warning: unused imports: `ResultExt`, `Result` Nov 30 14:06:44.383 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused import: `AsyncSink` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 6 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 7 | use futures::unsync::mpsc::UnboundedSender; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 8 | use take::Take; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 10 | use bincode; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] 13 | PacketId, TopicName}; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused imports: `ResultExt`, `Result` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused import: `std::ops::Deref` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:2:5 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 2 | use std::ops::Deref; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:4:16 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused imports: `AsyncSink`, `Poll` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:15 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.384 INFO [stderr] | ^^^^ ^^^^^^^^^ Nov 30 14:06:44.384 INFO [stderr] Nov 30 14:06:44.384 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.384 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:7:5 Nov 30 14:06:44.384 INFO [stderr] | Nov 30 14:06:44.384 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.384 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:8:5 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 8 | use futures::unsync::mpsc::UnboundedSender; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:9:5 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 9 | use take::Take; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:11:5 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 11 | use bincode; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:13:13 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] 14 | PacketId, TopicName}; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:16:21 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:17:5 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 17 | use errors::proto::ErrorKind as ProtoErrorKind; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:19:25 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:1:5 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 1 | use std::collections::hash_map::Entry; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused import: `std::ops::Deref` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:2:5 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 2 | use std::ops::Deref; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:5:16 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:6:28 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^^ ^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:7:5 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:9:5 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 9 | use take::Take; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:11:5 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 11 | use bincode; Nov 30 14:06:44.385 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.385 INFO [stderr] Nov 30 14:06:44.385 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Nov 30 14:06:44.385 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:13:25 Nov 30 14:06:44.385 INFO [stderr] | Nov 30 14:06:44.385 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:16:21 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:19:13 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 1 | use std::collections::hash_map::Entry; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused import: `std::ops::Deref` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 2 | use std::ops::Deref; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused import: `bytes::Bytes` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 4 | use bytes::Bytes; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused imports: `AsyncSink`, `Poll` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.386 INFO [stderr] | ^^^^ ^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 8 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 9 | use futures::unsync::mpsc::UnboundedSender; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 10 | use take::Take; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 12 | use bincode; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] 15 | PacketId, TopicName}; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused import: `Error` Nov 30 14:06:44.386 INFO [stderr] --> src/proto/types.rs:4:14 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 4 | use errors::{Error, ErrorKind}; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^ Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] warning: unused import: `Result` Nov 30 14:06:44.386 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Nov 30 14:06:44.386 INFO [stderr] | Nov 30 14:06:44.386 INFO [stderr] 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.386 INFO [stderr] | ^^^^^^ Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] = note: #[warn(unused_imports)] on by default Nov 30 14:06:44.386 INFO [stderr] Nov 30 14:06:44.386 INFO [stderr] warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused import: `linked_hash_map::LinkedHashMap` Nov 30 14:06:44.387 INFO [stderr] --> src/proto/types.rs:5:5 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 5 | use linked_hash_map::LinkedHashMap; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 1 | use std::collections::hash_map::Entry; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused import: `std::ops::Deref` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 2 | use std::ops::Deref; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused import: `bytes::Bytes` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 4 | use bytes::Bytes; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused import: `AsyncSink` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 9 | use take::Take; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] 14 | PacketId, TopicName}; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused import: `Result` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:1:5 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 1 | use std::collections::hash_map::Entry; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused import: `std::ops::Deref` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:2:5 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 2 | use std::ops::Deref; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.387 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:5:16 Nov 30 14:06:44.387 INFO [stderr] | Nov 30 14:06:44.387 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.387 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.387 INFO [stderr] Nov 30 14:06:44.387 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Nov 30 14:06:44.388 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:28 Nov 30 14:06:44.388 INFO [stderr] | Nov 30 14:06:44.388 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.388 INFO [stderr] | ^^^^^^^^^ ^^^^ Nov 30 14:06:44.388 INFO [stderr] Nov 30 14:06:44.388 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.388 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:7:5 Nov 30 14:06:44.388 INFO [stderr] | Nov 30 14:06:44.388 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.388 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.388 INFO [stderr] Nov 30 14:06:44.388 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.388 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:9:5 Nov 30 14:06:44.388 INFO [stderr] | Nov 30 14:06:44.388 INFO [stderr] 9 | use take::Take; Nov 30 14:06:44.388 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.388 INFO [stderr] Nov 30 14:06:44.388 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.388 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:11:5 Nov 30 14:06:44.388 INFO [stderr] | Nov 30 14:06:44.388 INFO [stderr] 11 | use bincode; Nov 30 14:06:44.388 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.388 INFO [stderr] Nov 30 14:06:44.388 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Nov 30 14:06:44.388 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:13:25 Nov 30 14:06:44.388 INFO [stderr] | Nov 30 14:06:44.388 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.388 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.388 INFO [stderr] Nov 30 14:06:44.388 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Nov 30 14:06:44.388 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:16:21 Nov 30 14:06:44.392 INFO [stderr] | Nov 30 14:06:44.392 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.393 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:19:13 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused imports: `IResult`, `be_u16` Nov 30 14:06:44.393 INFO [stderr] --> src/proto/headers.rs:3:11 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 3 | use nom::{IResult, be_u16}; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^ ^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused import: `std::io` Nov 30 14:06:44.393 INFO [stderr] --> src/proto/mod.rs:8:5 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 8 | use std::io; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused import: `Entry` Nov 30 14:06:44.393 INFO [stderr] --> src/proto/mod.rs:12:23 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 12 | use linked_hash_map::{Entry,LinkedHashMap}; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused import: `Writer` Nov 30 14:06:44.393 INFO [stderr] --> src/proto/mod.rs:13:38 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused import: `self::headers::*` Nov 30 14:06:44.393 INFO [stderr] --> src/proto/mod.rs:15:5 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 15 | use self::headers::*; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^^^^^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.393 INFO [stderr] --> src/tokio/mqtt_loop.rs:13:5 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 13 | use take::Take; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused import: `MqttFramedWriter` Nov 30 14:06:44.393 INFO [stderr] --> src/tokio/mqtt_loop.rs:21:13 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^^^^^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused import: `super::response::ResponseProcessor` Nov 30 14:06:44.393 INFO [stderr] --> src/tokio/mqtt_loop.rs:23:5 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 23 | use super::response::ResponseProcessor; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused import: `super::request::RequestProcessor` Nov 30 14:06:44.393 INFO [stderr] --> src/tokio/mqtt_loop.rs:24:5 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 24 | use super::request::RequestProcessor; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.393 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:1:16 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Nov 30 14:06:44.393 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:2:28 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^^^ ^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.393 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:4:5 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 4 | use take::Take; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.393 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:6:5 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 6 | use bincode; Nov 30 14:06:44.393 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.393 INFO [stderr] Nov 30 14:06:44.393 INFO [stderr] warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Nov 30 14:06:44.393 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:9:25 Nov 30 14:06:44.393 INFO [stderr] | Nov 30 14:06:44.393 INFO [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Nov 30 14:06:44.394 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Nov 30 14:06:44.394 INFO [stderr] Nov 30 14:06:44.394 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt` Nov 30 14:06:44.394 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:10:29 Nov 30 14:06:44.394 INFO [stderr] | Nov 30 14:06:44.394 INFO [stderr] 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.394 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.394 INFO [stderr] Nov 30 14:06:44.394 INFO [stderr] warning: unused import: `PublishState` Nov 30 14:06:44.394 INFO [stderr] --> src/tokio/outbound_handlers/ping_request.rs:12:25 Nov 30 14:06:44.394 INFO [stderr] | Nov 30 14:06:44.394 INFO [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Nov 30 14:06:44.394 INFO [stderr] | ^^^^^^^^^^^^ Nov 30 14:06:44.394 INFO [stderr] Nov 30 14:06:44.394 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.394 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:1:16 Nov 30 14:06:44.394 INFO [stderr] | Nov 30 14:06:44.394 INFO [stderr] 1 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.394 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.394 INFO [stderr] Nov 30 14:06:44.394 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Nov 30 14:06:44.394 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:2:28 Nov 30 14:06:44.394 INFO [stderr] | Nov 30 14:06:44.394 INFO [stderr] 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Nov 30 14:06:44.394 INFO [stderr] | ^^^^^^^^^ ^^^^ Nov 30 14:06:44.394 INFO [stderr] Nov 30 14:06:44.394 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.394 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:4:5 Nov 30 14:06:44.394 INFO [stderr] | Nov 30 14:06:44.394 INFO [stderr] 4 | use take::Take; Nov 30 14:06:44.394 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.394 INFO [stderr] Nov 30 14:06:44.397 INFO [stderr] warning: unused import: `PacketType` Nov 30 14:06:44.397 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:9:25 Nov 30 14:06:44.397 INFO [stderr] | Nov 30 14:06:44.397 INFO [stderr] 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Nov 30 14:06:44.397 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.397 INFO [stderr] Nov 30 14:06:44.397 INFO [stderr] warning: unused import: `OneTimeKey` Nov 30 14:06:44.397 INFO [stderr] --> src/tokio/outbound_handlers/publish.rs:12:13 Nov 30 14:06:44.397 INFO [stderr] | Nov 30 14:06:44.397 INFO [stderr] 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Nov 30 14:06:44.397 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.397 INFO [stderr] Nov 30 14:06:44.397 INFO [stderr] warning: unused import: `BoxFuture` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/outbound_handlers/mod.rs:8:27 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 8 | use tokio::{RequestTuple, BoxFuture}; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 3 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused import: `AsyncSink` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 6 | use futures::unsync::mpsc::UnboundedSender; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 7 | use take::Take; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 9 | use bincode; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] 12 | PacketId, TopicName}; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused imports: `ResultExt`, `Result` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused import: `AsyncSink` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 6 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 7 | use futures::unsync::mpsc::UnboundedSender; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 8 | use take::Take; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.398 INFO [stderr] 10 | use bincode; Nov 30 14:06:44.398 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.398 INFO [stderr] Nov 30 14:06:44.398 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Nov 30 14:06:44.398 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Nov 30 14:06:44.398 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] 13 | PacketId, TopicName}; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused imports: `ResultExt`, `Result` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused import: `std::ops::Deref` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:2:5 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 2 | use std::ops::Deref; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:4:16 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 4 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused imports: `AsyncSink`, `Poll` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:15 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.399 INFO [stderr] | ^^^^ ^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:7:5 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:8:5 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 8 | use futures::unsync::mpsc::UnboundedSender; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:9:5 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 9 | use take::Take; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:11:5 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 11 | use bincode; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:13:13 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] 14 | PacketId, TopicName}; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:16:21 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:17:5 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 17 | use errors::proto::ErrorKind as ProtoErrorKind; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:19:25 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:1:5 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 1 | use std::collections::hash_map::Entry; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.399 INFO [stderr] Nov 30 14:06:44.399 INFO [stderr] warning: unused import: `std::ops::Deref` Nov 30 14:06:44.399 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:2:5 Nov 30 14:06:44.399 INFO [stderr] | Nov 30 14:06:44.399 INFO [stderr] 2 | use std::ops::Deref; Nov 30 14:06:44.399 INFO [stderr] | ^^^^^^^^^^^^^^^ Nov 30 14:06:44.400 INFO [stderr] Nov 30 14:06:44.400 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.400 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:5:16 Nov 30 14:06:44.400 INFO [stderr] | Nov 30 14:06:44.400 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.400 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.400 INFO [stderr] Nov 30 14:06:44.400 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Nov 30 14:06:44.400 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:6:28 Nov 30 14:06:44.400 INFO [stderr] | Nov 30 14:06:44.400 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.400 INFO [stderr] | ^^^^^^^^^ ^^^^ Nov 30 14:06:44.400 INFO [stderr] Nov 30 14:06:44.400 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.400 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:7:5 Nov 30 14:06:44.400 INFO [stderr] | Nov 30 14:06:44.400 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.400 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.400 INFO [stderr] Nov 30 14:06:44.400 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.400 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:9:5 Nov 30 14:06:44.400 INFO [stderr] | Nov 30 14:06:44.400 INFO [stderr] 9 | use take::Take; Nov 30 14:06:44.400 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.400 INFO [stderr] Nov 30 14:06:44.400 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.400 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:11:5 Nov 30 14:06:44.400 INFO [stderr] | Nov 30 14:06:44.400 INFO [stderr] 11 | use bincode; Nov 30 14:06:44.400 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.405 INFO [stderr] Nov 30 14:06:44.405 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Nov 30 14:06:44.405 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:13:25 Nov 30 14:06:44.405 INFO [stderr] | Nov 30 14:06:44.405 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.405 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.405 INFO [stderr] Nov 30 14:06:44.405 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Nov 30 14:06:44.405 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:16:21 Nov 30 14:06:44.405 INFO [stderr] | Nov 30 14:06:44.405 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.405 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.405 INFO [stderr] Nov 30 14:06:44.405 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.405 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:19:13 Nov 30 14:06:44.405 INFO [stderr] | Nov 30 14:06:44.405 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Nov 30 14:06:44.405 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.405 INFO [stderr] Nov 30 14:06:44.405 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Nov 30 14:06:44.405 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Nov 30 14:06:44.405 INFO [stderr] | Nov 30 14:06:44.405 INFO [stderr] 1 | use std::collections::hash_map::Entry; Nov 30 14:06:44.405 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.405 INFO [stderr] Nov 30 14:06:44.405 INFO [stderr] warning: unused import: `std::ops::Deref` Nov 30 14:06:44.405 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Nov 30 14:06:44.405 INFO [stderr] | Nov 30 14:06:44.405 INFO [stderr] 2 | use std::ops::Deref; Nov 30 14:06:44.405 INFO [stderr] | ^^^^^^^^^^^^^^^ Nov 30 14:06:44.405 INFO [stderr] Nov 30 14:06:44.405 INFO [stderr] warning: unused import: `bytes::Bytes` Nov 30 14:06:44.405 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Nov 30 14:06:44.405 INFO [stderr] | Nov 30 14:06:44.405 INFO [stderr] 4 | use bytes::Bytes; Nov 30 14:06:44.405 INFO [stderr] | ^^^^^^^^^^^^ Nov 30 14:06:44.405 INFO [stderr] Nov 30 14:06:44.405 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.405 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Nov 30 14:06:44.405 INFO [stderr] | Nov 30 14:06:44.405 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.405 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.405 INFO [stderr] Nov 30 14:06:44.405 INFO [stderr] warning: unused imports: `AsyncSink`, `Poll` Nov 30 14:06:44.405 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Nov 30 14:06:44.405 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.406 INFO [stderr] | ^^^^ ^^^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 8 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused import: `futures::unsync::mpsc::UnboundedSender` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 9 | use futures::unsync::mpsc::UnboundedSender; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 10 | use take::Take; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 12 | use bincode; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] 15 | PacketId, TopicName}; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused import: `Result` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 1 | use std::collections::hash_map::Entry; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused import: `std::ops::Deref` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 2 | use std::ops::Deref; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^^^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused import: `bytes::Bytes` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 4 | use bytes::Bytes; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.406 INFO [stderr] Nov 30 14:06:44.406 INFO [stderr] warning: unused import: `AsyncSink` Nov 30 14:06:44.406 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Nov 30 14:06:44.406 INFO [stderr] | Nov 30 14:06:44.406 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.406 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 9 | use take::Take; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] 14 | PacketId, TopicName}; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused import: `Result` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused import: `std::collections::hash_map::Entry` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:1:5 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 1 | use std::collections::hash_map::Entry; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused import: `std::ops::Deref` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:2:5 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 2 | use std::ops::Deref; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused imports: `AsyncRead`, `AsyncWrite` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:5:16 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 5 | use tokio_io::{AsyncRead, AsyncWrite}; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^ ^^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused imports: `AsyncSink`, `Sink` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:28 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^ ^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused import: `futures::sync::mpsc::unbounded` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:7:5 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 7 | use futures::sync::mpsc::unbounded; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused import: `take::Take` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:9:5 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 9 | use take::Take; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused import: `bincode` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:11:5 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 11 | use bincode; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:13:25 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:16:21 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.407 INFO [stderr] 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Nov 30 14:06:44.407 INFO [stderr] | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.407 INFO [stderr] Nov 30 14:06:44.407 INFO [stderr] warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Nov 30 14:06:44.407 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:19:13 Nov 30 14:06:44.407 INFO [stderr] | Nov 30 14:06:44.408 INFO [stderr] 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Nov 30 14:06:44.408 INFO [stderr] | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Nov 30 14:06:44.408 INFO [stderr] Nov 30 14:06:44.472 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 Nov 30 14:06:44.472 INFO [stderr] --> src/types.rs:3:5 Nov 30 14:06:44.472 INFO [stderr] | Nov 30 14:06:44.472 INFO [stderr] 3 | use futures::future::BoxFuture; Nov 30 14:06:44.472 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.472 INFO [stderr] | Nov 30 14:06:44.472 INFO [stderr] = note: #[warn(deprecated)] on by default Nov 30 14:06:44.472 INFO [stderr] Nov 30 14:06:44.472 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 Nov 30 14:06:44.472 INFO [stderr] --> src/types.rs:5:5 Nov 30 14:06:44.472 INFO [stderr] | Nov 30 14:06:44.472 INFO [stderr] 5 | use futures::stream::BoxStream; Nov 30 14:06:44.472 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.472 INFO [stderr] Nov 30 14:06:44.472 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 Nov 30 14:06:44.472 INFO [stderr] --> src/types.rs:7:29 Nov 30 14:06:44.472 INFO [stderr] | Nov 30 14:06:44.472 INFO [stderr] 7 | pub type BoxMqttFuture = BoxFuture; Nov 30 14:06:44.473 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.473 INFO [stderr] Nov 30 14:06:44.473 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 Nov 30 14:06:44.473 INFO [stderr] --> src/types.rs:9:29 Nov 30 14:06:44.473 INFO [stderr] | Nov 30 14:06:44.473 INFO [stderr] 9 | pub type BoxMqttStream = BoxStream; Nov 30 14:06:44.473 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.473 INFO [stderr] Nov 30 14:06:44.476 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Nov 30 14:06:44.476 INFO [stderr] --> src/tokio/mod.rs:12:5 Nov 30 14:06:44.476 INFO [stderr] | Nov 30 14:06:44.476 INFO [stderr] 12 | use tokio_io::codec::Framed; Nov 30 14:06:44.476 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.476 INFO [stderr] Nov 30 14:06:44.476 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Nov 30 14:06:44.476 INFO [stderr] --> src/tokio/mod.rs:27:40 Nov 30 14:06:44.476 INFO [stderr] | Nov 30 14:06:44.476 INFO [stderr] 27 | type MqttFramedReader = SplitStream>; Nov 30 14:06:44.476 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.476 INFO [stderr] Nov 30 14:06:44.476 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Nov 30 14:06:44.476 INFO [stderr] --> src/tokio/mod.rs:28:38 Nov 30 14:06:44.476 INFO [stderr] | Nov 30 14:06:44.476 INFO [stderr] 28 | type MqttFramedWriter = SplitSink>; Nov 30 14:06:44.476 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.476 INFO [stderr] Nov 30 14:06:44.598 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 Nov 30 14:06:44.598 INFO [stderr] --> src/types.rs:3:5 Nov 30 14:06:44.598 INFO [stderr] | Nov 30 14:06:44.598 INFO [stderr] 3 | use futures::future::BoxFuture; Nov 30 14:06:44.598 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.598 INFO [stderr] | Nov 30 14:06:44.598 INFO [stderr] = note: #[warn(deprecated)] on by default Nov 30 14:06:44.598 INFO [stderr] Nov 30 14:06:44.598 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 Nov 30 14:06:44.598 INFO [stderr] --> src/types.rs:5:5 Nov 30 14:06:44.598 INFO [stderr] | Nov 30 14:06:44.598 INFO [stderr] 5 | use futures::stream::BoxStream; Nov 30 14:06:44.598 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.598 INFO [stderr] Nov 30 14:06:44.598 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 Nov 30 14:06:44.598 INFO [stderr] --> src/types.rs:7:29 Nov 30 14:06:44.598 INFO [stderr] | Nov 30 14:06:44.598 INFO [stderr] 7 | pub type BoxMqttFuture = BoxFuture; Nov 30 14:06:44.598 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.598 INFO [stderr] Nov 30 14:06:44.598 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 Nov 30 14:06:44.598 INFO [stderr] --> src/types.rs:9:29 Nov 30 14:06:44.598 INFO [stderr] | Nov 30 14:06:44.598 INFO [stderr] 9 | pub type BoxMqttStream = BoxStream; Nov 30 14:06:44.598 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.598 INFO [stderr] Nov 30 14:06:44.616 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Nov 30 14:06:44.616 INFO [stderr] --> src/tokio/mod.rs:12:5 Nov 30 14:06:44.616 INFO [stderr] | Nov 30 14:06:44.616 INFO [stderr] 12 | use tokio_io::codec::Framed; Nov 30 14:06:44.616 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.616 INFO [stderr] Nov 30 14:06:44.616 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Nov 30 14:06:44.616 INFO [stderr] --> src/tokio/mod.rs:27:40 Nov 30 14:06:44.616 INFO [stderr] | Nov 30 14:06:44.616 INFO [stderr] 27 | type MqttFramedReader = SplitStream>; Nov 30 14:06:44.616 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.616 INFO [stderr] Nov 30 14:06:44.616 INFO [stderr] warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Nov 30 14:06:44.616 INFO [stderr] --> src/tokio/mod.rs:28:38 Nov 30 14:06:44.616 INFO [stderr] | Nov 30 14:06:44.616 INFO [stderr] 28 | type MqttFramedWriter = SplitSink>; Nov 30 14:06:44.616 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:44.616 INFO [stderr] Nov 30 14:06:44.992 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Nov 30 14:06:44.992 INFO [stderr] --> src/proto/types.rs:271:13 Nov 30 14:06:44.992 INFO [stderr] | Nov 30 14:06:44.992 INFO [stderr] 271 | out.put_u16::(self.len() as u16); Nov 30 14:06:44.992 INFO [stderr] | ^^^^^^^ Nov 30 14:06:44.992 INFO [stderr] Nov 30 14:06:45.124 INFO [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Nov 30 14:06:45.124 INFO [stderr] --> src/proto/headers.rs:135:40 Nov 30 14:06:45.124 INFO [stderr] | Nov 30 14:06:45.124 INFO [stderr] 135 | Ok(PacketId(raw.into_buf().get_u16::())) Nov 30 14:06:45.124 INFO [stderr] | ^^^^^^^ Nov 30 14:06:45.124 INFO [stderr] Nov 30 14:06:45.124 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Nov 30 14:06:45.124 INFO [stderr] --> src/proto/headers.rs:140:13 Nov 30 14:06:45.124 INFO [stderr] | Nov 30 14:06:45.124 INFO [stderr] 140 | out.put_u16::(self.0); Nov 30 14:06:45.124 INFO [stderr] | ^^^^^^^ Nov 30 14:06:45.124 INFO [stderr] Nov 30 14:06:45.124 INFO [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Nov 30 14:06:45.124 INFO [stderr] --> src/proto/headers.rs:170:41 Nov 30 14:06:45.124 INFO [stderr] | Nov 30 14:06:45.124 INFO [stderr] 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Nov 30 14:06:45.124 INFO [stderr] | ^^^^^^^ Nov 30 14:06:45.124 INFO [stderr] Nov 30 14:06:45.124 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Nov 30 14:06:45.124 INFO [stderr] --> src/proto/headers.rs:175:13 Nov 30 14:06:45.124 INFO [stderr] | Nov 30 14:06:45.124 INFO [stderr] 175 | out.put_u16::(self.0); Nov 30 14:06:45.125 INFO [stderr] | ^^^^^^^ Nov 30 14:06:45.125 INFO [stderr] Nov 30 14:06:45.160 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 Nov 30 14:06:45.160 INFO [stderr] --> src/client.rs:223:55 Nov 30 14:06:45.160 INFO [stderr] | Nov 30 14:06:45.160 INFO [stderr] 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Nov 30 14:06:45.160 INFO [stderr] | ^^^^^ Nov 30 14:06:45.160 INFO [stderr] Nov 30 14:06:45.172 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 Nov 30 14:06:45.172 INFO [stderr] --> src/client.rs:266:63 Nov 30 14:06:45.172 INFO [stderr] | Nov 30 14:06:45.172 INFO [stderr] 266 | client.request(connect).into_future().map(|_| ()).boxed() Nov 30 14:06:45.172 INFO [stderr] | ^^^^^ Nov 30 14:06:45.172 INFO [stderr] Nov 30 14:06:45.212 INFO [stderr] warning: use of deprecated item '>::send': renamed to `unbounded_send` Nov 30 14:06:45.212 INFO [stderr] --> src/tokio/mqtt_loop.rs:54:32 Nov 30 14:06:45.212 INFO [stderr] | Nov 30 14:06:45.212 INFO [stderr] 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Nov 30 14:06:45.212 INFO [stderr] | ^^^^ Nov 30 14:06:45.212 INFO [stderr] Nov 30 14:06:45.216 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 Nov 30 14:06:45.216 INFO [stderr] --> src/tokio/mqtt_loop.rs:60:47 Nov 30 14:06:45.216 INFO [stderr] | Nov 30 14:06:45.216 INFO [stderr] 60 | Ok((next_state(sender), Ok(rx.boxed()))) Nov 30 14:06:45.216 INFO [stderr] | ^^^^^ Nov 30 14:06:45.216 INFO [stderr] Nov 30 14:06:45.224 INFO [stderr] warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Nov 30 14:06:45.224 INFO [stderr] --> src/tokio/mqtt_loop.rs:266:34 Nov 30 14:06:45.224 INFO [stderr] | Nov 30 14:06:45.224 INFO [stderr] 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Nov 30 14:06:45.224 INFO [stderr] | ^^^^^^ Nov 30 14:06:45.224 INFO [stderr] Nov 30 14:06:45.240 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 Nov 30 14:06:45.240 INFO [stderr] --> src/tokio/mqtt_loop.rs:317:14 Nov 30 14:06:45.240 INFO [stderr] | Nov 30 14:06:45.240 INFO [stderr] 317 | .boxed() Nov 30 14:06:45.240 INFO [stderr] | ^^^^^ Nov 30 14:06:45.240 INFO [stderr] Nov 30 14:06:45.256 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 Nov 30 14:06:45.256 INFO [stderr] --> src/tokio/mqtt_loop.rs:519:42 Nov 30 14:06:45.256 INFO [stderr] | Nov 30 14:06:45.256 INFO [stderr] 519 | .boxed(), Nov 30 14:06:45.256 INFO [stderr] | ^^^^^ Nov 30 14:06:45.256 INFO [stderr] Nov 30 14:06:45.268 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 Nov 30 14:06:45.268 INFO [stderr] --> src/tokio/response.rs:83:40 Nov 30 14:06:45.268 INFO [stderr] | Nov 30 14:06:45.271 INFO [stderr] 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Nov 30 14:06:45.271 INFO [stderr] | ^^^^^ Nov 30 14:06:45.271 INFO [stderr] Nov 30 14:06:45.324 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 Nov 30 14:06:45.324 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Nov 30 14:06:45.324 INFO [stderr] | Nov 30 14:06:45.324 INFO [stderr] 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Nov 30 14:06:45.324 INFO [stderr] | ^^^^^ Nov 30 14:06:45.324 INFO [stderr] Nov 30 14:06:45.530 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Nov 30 14:06:45.530 INFO [stderr] --> src/proto/types.rs:271:13 Nov 30 14:06:45.530 INFO [stderr] | Nov 30 14:06:45.530 INFO [stderr] 271 | out.put_u16::(self.len() as u16); Nov 30 14:06:45.530 INFO [stderr] | ^^^^^^^ Nov 30 14:06:45.530 INFO [stderr] Nov 30 14:06:45.684 INFO [stderr] warning: unused import: `Sink` Nov 30 14:06:45.684 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Nov 30 14:06:45.684 INFO [stderr] | Nov 30 14:06:45.684 INFO [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:45.684 INFO [stderr] | ^^^^ Nov 30 14:06:45.684 INFO [stderr] Nov 30 14:06:45.684 INFO [stderr] warning: unused import: `Sink` Nov 30 14:06:45.684 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Nov 30 14:06:45.684 INFO [stderr] | Nov 30 14:06:45.684 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:45.684 INFO [stderr] | ^^^^ Nov 30 14:06:45.684 INFO [stderr] Nov 30 14:06:45.684 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:45.684 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Nov 30 14:06:45.684 INFO [stderr] | Nov 30 14:06:45.684 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:45.684 INFO [stderr] | ^^^^^^ Nov 30 14:06:45.685 INFO [stderr] Nov 30 14:06:45.685 INFO [stderr] warning: unused import: `Sink` Nov 30 14:06:45.685 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:39 Nov 30 14:06:45.685 INFO [stderr] | Nov 30 14:06:45.685 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:45.685 INFO [stderr] | ^^^^ Nov 30 14:06:45.685 INFO [stderr] Nov 30 14:06:45.685 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:45.685 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:53 Nov 30 14:06:45.685 INFO [stderr] | Nov 30 14:06:45.685 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:45.685 INFO [stderr] | ^^^^^^ Nov 30 14:06:45.685 INFO [stderr] Nov 30 14:06:45.685 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:45.685 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:6:53 Nov 30 14:06:45.685 INFO [stderr] | Nov 30 14:06:45.685 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:45.685 INFO [stderr] | ^^^^^^ Nov 30 14:06:45.685 INFO [stderr] Nov 30 14:06:45.685 INFO [stderr] warning: unused import: `Sink` Nov 30 14:06:45.685 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Nov 30 14:06:45.685 INFO [stderr] | Nov 30 14:06:45.685 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:45.685 INFO [stderr] | ^^^^ Nov 30 14:06:45.685 INFO [stderr] Nov 30 14:06:45.685 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:45.685 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Nov 30 14:06:45.685 INFO [stderr] | Nov 30 14:06:45.685 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:45.685 INFO [stderr] | ^^^^^^ Nov 30 14:06:45.685 INFO [stderr] Nov 30 14:06:45.685 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:45.685 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Nov 30 14:06:45.685 INFO [stderr] | Nov 30 14:06:45.685 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:45.685 INFO [stderr] | ^^^^^^ Nov 30 14:06:45.685 INFO [stderr] Nov 30 14:06:45.685 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:45.685 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:53 Nov 30 14:06:45.685 INFO [stderr] | Nov 30 14:06:45.685 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:45.685 INFO [stderr] | ^^^^^^ Nov 30 14:06:45.685 INFO [stderr] Nov 30 14:06:45.748 INFO [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Nov 30 14:06:45.748 INFO [stderr] --> src/proto/headers.rs:135:40 Nov 30 14:06:45.748 INFO [stderr] | Nov 30 14:06:45.748 INFO [stderr] 135 | Ok(PacketId(raw.into_buf().get_u16::())) Nov 30 14:06:45.748 INFO [stderr] | ^^^^^^^ Nov 30 14:06:45.748 INFO [stderr] Nov 30 14:06:45.748 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Nov 30 14:06:45.748 INFO [stderr] --> src/proto/headers.rs:140:13 Nov 30 14:06:45.748 INFO [stderr] | Nov 30 14:06:45.748 INFO [stderr] 140 | out.put_u16::(self.0); Nov 30 14:06:45.748 INFO [stderr] | ^^^^^^^ Nov 30 14:06:45.748 INFO [stderr] Nov 30 14:06:45.763 INFO [stderr] warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Nov 30 14:06:45.763 INFO [stderr] --> src/proto/headers.rs:170:41 Nov 30 14:06:45.763 INFO [stderr] | Nov 30 14:06:45.763 INFO [stderr] 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Nov 30 14:06:45.763 INFO [stderr] | ^^^^^^^ Nov 30 14:06:45.763 INFO [stderr] Nov 30 14:06:45.763 INFO [stderr] warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Nov 30 14:06:45.763 INFO [stderr] --> src/proto/headers.rs:175:13 Nov 30 14:06:45.763 INFO [stderr] | Nov 30 14:06:45.763 INFO [stderr] 175 | out.put_u16::(self.0); Nov 30 14:06:45.763 INFO [stderr] | ^^^^^^^ Nov 30 14:06:45.763 INFO [stderr] Nov 30 14:06:45.793 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 Nov 30 14:06:45.793 INFO [stderr] --> src/client.rs:223:55 Nov 30 14:06:45.793 INFO [stderr] | Nov 30 14:06:45.793 INFO [stderr] 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Nov 30 14:06:45.793 INFO [stderr] | ^^^^^ Nov 30 14:06:45.793 INFO [stderr] Nov 30 14:06:45.816 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 Nov 30 14:06:45.816 INFO [stderr] --> src/client.rs:266:63 Nov 30 14:06:45.816 INFO [stderr] | Nov 30 14:06:45.816 INFO [stderr] 266 | client.request(connect).into_future().map(|_| ()).boxed() Nov 30 14:06:45.816 INFO [stderr] | ^^^^^ Nov 30 14:06:45.816 INFO [stderr] Nov 30 14:06:45.904 INFO [stderr] warning: use of deprecated item '>::send': renamed to `unbounded_send` Nov 30 14:06:45.904 INFO [stderr] --> src/tokio/mqtt_loop.rs:54:32 Nov 30 14:06:45.904 INFO [stderr] | Nov 30 14:06:45.904 INFO [stderr] 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Nov 30 14:06:45.904 INFO [stderr] | ^^^^ Nov 30 14:06:45.904 INFO [stderr] Nov 30 14:06:45.904 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 Nov 30 14:06:45.908 INFO [stderr] --> src/tokio/mqtt_loop.rs:60:47 Nov 30 14:06:45.908 INFO [stderr] | Nov 30 14:06:45.908 INFO [stderr] 60 | Ok((next_state(sender), Ok(rx.boxed()))) Nov 30 14:06:45.908 INFO [stderr] | ^^^^^ Nov 30 14:06:45.908 INFO [stderr] Nov 30 14:06:45.928 INFO [stderr] warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Nov 30 14:06:45.928 INFO [stderr] --> src/tokio/mqtt_loop.rs:266:34 Nov 30 14:06:45.928 INFO [stderr] | Nov 30 14:06:45.928 INFO [stderr] 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Nov 30 14:06:45.928 INFO [stderr] | ^^^^^^ Nov 30 14:06:45.928 INFO [stderr] Nov 30 14:06:45.972 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 Nov 30 14:06:45.972 INFO [stderr] --> src/tokio/mqtt_loop.rs:317:14 Nov 30 14:06:45.972 INFO [stderr] | Nov 30 14:06:45.972 INFO [stderr] 317 | .boxed() Nov 30 14:06:45.972 INFO [stderr] | ^^^^^ Nov 30 14:06:45.972 INFO [stderr] Nov 30 14:06:45.992 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 Nov 30 14:06:45.992 INFO [stderr] --> src/tokio/mqtt_loop.rs:519:42 Nov 30 14:06:45.992 INFO [stderr] | Nov 30 14:06:45.992 INFO [stderr] 519 | .boxed(), Nov 30 14:06:45.992 INFO [stderr] | ^^^^^ Nov 30 14:06:45.992 INFO [stderr] Nov 30 14:06:46.022 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 Nov 30 14:06:46.022 INFO [stderr] --> src/tokio/response.rs:83:40 Nov 30 14:06:46.022 INFO [stderr] | Nov 30 14:06:46.022 INFO [stderr] 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Nov 30 14:06:46.022 INFO [stderr] | ^^^^^ Nov 30 14:06:46.022 INFO [stderr] Nov 30 14:06:46.084 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 Nov 30 14:06:46.084 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Nov 30 14:06:46.084 INFO [stderr] | Nov 30 14:06:46.084 INFO [stderr] 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Nov 30 14:06:46.084 INFO [stderr] | ^^^^^ Nov 30 14:06:46.084 INFO [stderr] Nov 30 14:06:46.408 INFO [stderr] warning: unused import: `Sink` Nov 30 14:06:46.408 INFO [stderr] --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Nov 30 14:06:46.408 INFO [stderr] | Nov 30 14:06:46.408 INFO [stderr] 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:46.408 INFO [stderr] | ^^^^ Nov 30 14:06:46.408 INFO [stderr] Nov 30 14:06:46.408 INFO [stderr] warning: unused import: `Sink` Nov 30 14:06:46.408 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Nov 30 14:06:46.408 INFO [stderr] | Nov 30 14:06:46.409 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:46.409 INFO [stderr] | ^^^^ Nov 30 14:06:46.409 INFO [stderr] Nov 30 14:06:46.409 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:46.409 INFO [stderr] --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Nov 30 14:06:46.409 INFO [stderr] | Nov 30 14:06:46.409 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:46.409 INFO [stderr] | ^^^^^^ Nov 30 14:06:46.409 INFO [stderr] Nov 30 14:06:46.409 INFO [stderr] warning: unused import: `Sink` Nov 30 14:06:46.409 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:39 Nov 30 14:06:46.409 INFO [stderr] | Nov 30 14:06:46.409 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:46.409 INFO [stderr] | ^^^^ Nov 30 14:06:46.409 INFO [stderr] Nov 30 14:06:46.409 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:46.409 INFO [stderr] --> src/tokio/inbound_handlers/ping_response.rs:5:53 Nov 30 14:06:46.409 INFO [stderr] | Nov 30 14:06:46.409 INFO [stderr] 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:46.409 INFO [stderr] | ^^^^^^ Nov 30 14:06:46.409 INFO [stderr] Nov 30 14:06:46.409 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:46.409 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:6:53 Nov 30 14:06:46.409 INFO [stderr] | Nov 30 14:06:46.409 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:46.409 INFO [stderr] | ^^^^^^ Nov 30 14:06:46.409 INFO [stderr] Nov 30 14:06:46.409 INFO [stderr] warning: unused import: `Sink` Nov 30 14:06:46.409 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Nov 30 14:06:46.409 INFO [stderr] | Nov 30 14:06:46.409 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:46.409 INFO [stderr] | ^^^^ Nov 30 14:06:46.409 INFO [stderr] Nov 30 14:06:46.409 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:46.409 INFO [stderr] --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Nov 30 14:06:46.409 INFO [stderr] | Nov 30 14:06:46.409 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:46.409 INFO [stderr] | ^^^^^^ Nov 30 14:06:46.409 INFO [stderr] Nov 30 14:06:46.409 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:46.409 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Nov 30 14:06:46.409 INFO [stderr] | Nov 30 14:06:46.409 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:46.409 INFO [stderr] | ^^^^^^ Nov 30 14:06:46.409 INFO [stderr] Nov 30 14:06:46.409 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:46.409 INFO [stderr] --> src/tokio/inbound_handlers/publish_release.rs:6:53 Nov 30 14:06:46.409 INFO [stderr] | Nov 30 14:06:46.409 INFO [stderr] 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Nov 30 14:06:46.409 INFO [stderr] | ^^^^^^ Nov 30 14:06:46.409 INFO [stderr] Nov 30 14:06:46.416 INFO [stderr] warning: variable does not need to be mutable Nov 30 14:06:46.416 INFO [stderr] --> src/tokio/mqtt_loop.rs:320:31 Nov 30 14:06:46.416 INFO [stderr] | Nov 30 14:06:46.416 INFO [stderr] 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Nov 30 14:06:46.416 INFO [stderr] | ----^^^ Nov 30 14:06:46.416 INFO [stderr] | | Nov 30 14:06:46.416 INFO [stderr] | help: remove this `mut` Nov 30 14:06:46.416 INFO [stderr] | Nov 30 14:06:46.416 INFO [stderr] = note: #[warn(unused_mut)] on by default Nov 30 14:06:46.416 INFO [stderr] Nov 30 14:06:46.684 INFO [stderr] warning: unused `std::result::Result` that must be used Nov 30 14:06:46.684 INFO [stderr] --> src/tokio/mqtt_loop.rs:571:17 Nov 30 14:06:46.684 INFO [stderr] | Nov 30 14:06:46.684 INFO [stderr] 571 | self.poll_queues(sourceitem); Nov 30 14:06:46.684 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:46.684 INFO [stderr] | Nov 30 14:06:46.684 INFO [stderr] = note: #[warn(unused_must_use)] on by default Nov 30 14:06:46.684 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Nov 30 14:06:46.684 INFO [stderr] Nov 30 14:06:46.684 INFO [stderr] warning: unused `std::result::Result` that must be used Nov 30 14:06:46.684 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:104:25 Nov 30 14:06:46.684 INFO [stderr] | Nov 30 14:06:46.684 INFO [stderr] 104 | / requester.unbounded_send(LoopRequest::Internal( Nov 30 14:06:46.684 INFO [stderr] 105 | | MqttPacket::pub_ack_packet(*id), Nov 30 14:06:46.684 INFO [stderr] 106 | | )); Nov 30 14:06:46.684 INFO [stderr] | |___________________________^ Nov 30 14:06:46.684 INFO [stderr] | Nov 30 14:06:46.684 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Nov 30 14:06:46.684 INFO [stderr] Nov 30 14:06:46.684 INFO [stderr] warning: unused `std::result::Result` that must be used Nov 30 14:06:46.684 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:128:29 Nov 30 14:06:46.685 INFO [stderr] | Nov 30 14:06:46.685 INFO [stderr] 128 | / requester.unbounded_send( Nov 30 14:06:46.685 INFO [stderr] 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Nov 30 14:06:46.685 INFO [stderr] 130 | | ); Nov 30 14:06:46.685 INFO [stderr] | |______________________________^ Nov 30 14:06:46.685 INFO [stderr] | Nov 30 14:06:46.685 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Nov 30 14:06:46.685 INFO [stderr] Nov 30 14:06:46.685 INFO [stderr] warning: unused `futures::sink::Send` that must be used Nov 30 14:06:46.685 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Nov 30 14:06:46.685 INFO [stderr] | Nov 30 14:06:46.685 INFO [stderr] 100 | requester.send(LoopRequest::Internal(rel)); Nov 30 14:06:46.685 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:46.685 INFO [stderr] | Nov 30 14:06:46.685 INFO [stderr] = note: futures do nothing unless polled Nov 30 14:06:46.685 INFO [stderr] Nov 30 14:06:46.868 INFO [stderr] warning: variable does not need to be mutable Nov 30 14:06:46.868 INFO [stderr] --> src/tokio/mqtt_loop.rs:320:31 Nov 30 14:06:46.868 INFO [stderr] | Nov 30 14:06:46.868 INFO [stderr] 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Nov 30 14:06:46.868 INFO [stderr] | ----^^^ Nov 30 14:06:46.868 INFO [stderr] | | Nov 30 14:06:46.868 INFO [stderr] | help: remove this `mut` Nov 30 14:06:46.868 INFO [stderr] | Nov 30 14:06:46.868 INFO [stderr] = note: #[warn(unused_mut)] on by default Nov 30 14:06:46.868 INFO [stderr] Nov 30 14:06:47.133 INFO [stderr] warning: unused `std::result::Result` that must be used Nov 30 14:06:47.133 INFO [stderr] --> src/tokio/mqtt_loop.rs:571:17 Nov 30 14:06:47.133 INFO [stderr] | Nov 30 14:06:47.133 INFO [stderr] 571 | self.poll_queues(sourceitem); Nov 30 14:06:47.133 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:47.133 INFO [stderr] | Nov 30 14:06:47.133 INFO [stderr] = note: #[warn(unused_must_use)] on by default Nov 30 14:06:47.133 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Nov 30 14:06:47.133 INFO [stderr] Nov 30 14:06:47.135 INFO [stderr] warning: unused `std::result::Result` that must be used Nov 30 14:06:47.135 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:104:25 Nov 30 14:06:47.135 INFO [stderr] | Nov 30 14:06:47.135 INFO [stderr] 104 | / requester.unbounded_send(LoopRequest::Internal( Nov 30 14:06:47.135 INFO [stderr] 105 | | MqttPacket::pub_ack_packet(*id), Nov 30 14:06:47.135 INFO [stderr] 106 | | )); Nov 30 14:06:47.135 INFO [stderr] | |___________________________^ Nov 30 14:06:47.135 INFO [stderr] | Nov 30 14:06:47.135 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Nov 30 14:06:47.135 INFO [stderr] Nov 30 14:06:47.135 INFO [stderr] warning: unused `std::result::Result` that must be used Nov 30 14:06:47.135 INFO [stderr] --> src/tokio/inbound_handlers/publish.rs:128:29 Nov 30 14:06:47.135 INFO [stderr] | Nov 30 14:06:47.135 INFO [stderr] 128 | / requester.unbounded_send( Nov 30 14:06:47.135 INFO [stderr] 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Nov 30 14:06:47.135 INFO [stderr] 130 | | ); Nov 30 14:06:47.135 INFO [stderr] | |______________________________^ Nov 30 14:06:47.135 INFO [stderr] | Nov 30 14:06:47.135 INFO [stderr] = note: this `Result` may be an `Err` variant, which should be handled Nov 30 14:06:47.135 INFO [stderr] Nov 30 14:06:47.135 INFO [stderr] warning: unused `futures::sink::Send` that must be used Nov 30 14:06:47.135 INFO [stderr] --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Nov 30 14:06:47.135 INFO [stderr] | Nov 30 14:06:47.135 INFO [stderr] 100 | requester.send(LoopRequest::Internal(rel)); Nov 30 14:06:47.135 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:47.135 INFO [stderr] | Nov 30 14:06:47.136 INFO [stderr] = note: futures do nothing unless polled Nov 30 14:06:47.136 INFO [stderr] Nov 30 14:06:52.749 INFO [stderr] warning: unused `#[macro_use]` import Nov 30 14:06:52.749 INFO [stderr] --> examples/client.rs:1:1 Nov 30 14:06:52.749 INFO [stderr] | Nov 30 14:06:52.749 INFO [stderr] 1 | #[macro_use] Nov 30 14:06:52.749 INFO [stderr] | ^^^^^^^^^^^^ Nov 30 14:06:52.749 INFO [stderr] | Nov 30 14:06:52.749 INFO [stderr] = note: #[warn(unused_imports)] on by default Nov 30 14:06:52.749 INFO [stderr] Nov 30 14:06:52.749 INFO [stderr] warning: unused import: `tokio_mqttc::persistence::*` Nov 30 14:06:52.749 INFO [stderr] --> examples/client.rs:11:5 Nov 30 14:06:52.749 INFO [stderr] | Nov 30 14:06:52.749 INFO [stderr] 11 | use tokio_mqttc::persistence::*; Nov 30 14:06:52.749 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:52.749 INFO [stderr] Nov 30 14:06:52.750 INFO [stderr] warning: unused import: `tokio_mqttc::proto::*` Nov 30 14:06:52.750 INFO [stderr] --> examples/client.rs:13:5 Nov 30 14:06:52.750 INFO [stderr] | Nov 30 14:06:52.750 INFO [stderr] 13 | use tokio_mqttc::proto::*; Nov 30 14:06:52.750 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:52.750 INFO [stderr] Nov 30 14:06:52.750 INFO [stderr] warning: unused import: `tokio_core::reactor::Handle` Nov 30 14:06:52.750 INFO [stderr] --> examples/client.rs:41:5 Nov 30 14:06:52.750 INFO [stderr] | Nov 30 14:06:52.751 INFO [stderr] 41 | use tokio_core::reactor::Handle; Nov 30 14:06:52.751 INFO [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Nov 30 14:06:52.751 INFO [stderr] Nov 30 14:06:52.751 INFO [stderr] warning: unused imports: `Sink`, `future` Nov 30 14:06:52.752 INFO [stderr] --> examples/client.rs:45:15 Nov 30 14:06:52.752 INFO [stderr] | Nov 30 14:06:52.752 INFO [stderr] 45 | use futures::{future, Future, Stream, Sink}; Nov 30 14:06:52.752 INFO [stderr] | ^^^^^^ ^^^^ Nov 30 14:06:52.752 INFO [stderr] Nov 30 14:06:52.881 INFO [stderr] warning: unused import: `Stream` Nov 30 14:06:52.881 INFO [stderr] --> examples/client.rs:45:31 Nov 30 14:06:52.881 INFO [stderr] | Nov 30 14:06:52.881 INFO [stderr] 45 | use futures::{future, Future, Stream, Sink}; Nov 30 14:06:52.881 INFO [stderr] | ^^^^^^ Nov 30 14:06:52.881 INFO [stderr] Nov 30 14:06:52.959 INFO [stderr] Finished dev [unoptimized + debuginfo] target(s) in 16.56s Nov 30 14:06:52.971 INFO [stderr] su: No module specific data is present Nov 30 14:06:53.702 INFO running `"docker" "inspect" "9c73feb0fbc74c0ec355f2332c7e7b47426cd7afe3de5fe021b4f8f36d5f4911"` Nov 30 14:06:54.130 INFO running `"docker" "rm" "-f" "9c73feb0fbc74c0ec355f2332c7e7b47426cd7afe3de5fe021b4f8f36d5f4911"` Nov 30 14:06:54.516 INFO [stdout] 9c73feb0fbc74c0ec355f2332c7e7b47426cd7afe3de5fe021b4f8f36d5f4911