Sep 14 07:34:09.067 INFO checking tokio-mqttc-0.0.2 against try#87b8e7411c4f1267d0cac0d63fa9c21c943e2ea0 for pr-53578-1 Sep 14 07:34:09.067 INFO running: cargo +87b8e7411c4f1267d0cac0d63fa9c21c943e2ea0-alt check --frozen --all --all-targets Sep 14 07:34:09.067 INFO running `"docker" "create" "-v" "/home/ec2-user/crater/./work/local/test-source/worker-7/pr-53578-1/try#87b8e7411c4f1267d0cac0d63fa9c21c943e2ea0:/source:ro,Z" "-v" "/home/ec2-user/crater/./work/local/target-dirs/pr-53578-1/worker-7/try#87b8e7411c4f1267d0cac0d63fa9c21c943e2ea0:/target:rw,Z" "-v" "/home/ec2-user/crater/./work/local/cargo-home:/cargo-home:ro,Z" "-v" "/home/ec2-user/crater/./work/local/rustup-home:/rustup-home:ro,Z" "-e" "USER_ID=1000" "-e" "CMD=cargo +87b8e7411c4f1267d0cac0d63fa9c21c943e2ea0-alt check --frozen --all --all-targets" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-m" "2G" "crater"` Sep 14 07:34:09.199 INFO blam! 9037106d2030db4f053b5df3a4b033af442f08609dfddfe5c826b27675513b51 Sep 14 07:34:09.200 INFO running `"docker" "start" "-a" "9037106d2030db4f053b5df3a4b033af442f08609dfddfe5c826b27675513b51"` Sep 14 07:34:10.672 INFO kablam! usermod: no changes Sep 14 07:34:10.823 INFO kablam! Checking nom v2.2.1 Sep 14 07:34:10.825 INFO kablam! Checking futures-mutex v0.1.2 Sep 14 07:34:10.825 INFO kablam! Checking touch v0.0.1 Sep 14 07:34:10.830 INFO kablam! Checking bincode v0.9.2 Sep 14 07:34:10.830 INFO kablam! Checking linked-hash-map v0.5.1 Sep 14 07:34:13.106 INFO kablam! Checking nom-test-helpers v2.0.0 Sep 14 07:34:13.107 INFO kablam! Checking tokio-mqttc v0.0.2 (file:///source) Sep 14 07:34:14.462 INFO kablam! warning: unused import: `Error` Sep 14 07:34:14.462 INFO kablam! --> src/proto/types.rs:4:14 Sep 14 07:34:14.462 INFO kablam! | Sep 14 07:34:14.462 INFO kablam! 4 | use errors::{Error, ErrorKind}; Sep 14 07:34:14.462 INFO kablam! | ^^^^^ Sep 14 07:34:14.467 INFO kablam! | Sep 14 07:34:14.467 INFO kablam! = note: #[warn(unused_imports)] on by default Sep 14 07:34:14.467 INFO kablam! Sep 14 07:34:14.467 INFO kablam! warning: unused import: `linked_hash_map::LinkedHashMap` Sep 14 07:34:14.467 INFO kablam! --> src/proto/types.rs:5:5 Sep 14 07:34:14.467 INFO kablam! | Sep 14 07:34:14.467 INFO kablam! 5 | use linked_hash_map::LinkedHashMap; Sep 14 07:34:14.467 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.467 INFO kablam! Sep 14 07:34:14.476 INFO kablam! warning: unused imports: `IResult`, `be_u16` Sep 14 07:34:14.476 INFO kablam! --> src/proto/headers.rs:3:11 Sep 14 07:34:14.476 INFO kablam! | Sep 14 07:34:14.476 INFO kablam! 3 | use nom::{IResult, be_u16}; Sep 14 07:34:14.476 INFO kablam! | ^^^^^^^ ^^^^^^ Sep 14 07:34:14.476 INFO kablam! Sep 14 07:34:14.476 INFO kablam! warning: unused import: `std::io` Sep 14 07:34:14.476 INFO kablam! --> src/proto/mod.rs:8:5 Sep 14 07:34:14.476 INFO kablam! | Sep 14 07:34:14.476 INFO kablam! 8 | use std::io; Sep 14 07:34:14.476 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.476 INFO kablam! Sep 14 07:34:14.476 INFO kablam! warning: unused import: `Entry` Sep 14 07:34:14.476 INFO kablam! --> src/proto/mod.rs:12:23 Sep 14 07:34:14.476 INFO kablam! | Sep 14 07:34:14.476 INFO kablam! 12 | use linked_hash_map::{Entry,LinkedHashMap}; Sep 14 07:34:14.476 INFO kablam! | ^^^^^ Sep 14 07:34:14.476 INFO kablam! Sep 14 07:34:14.476 INFO kablam! warning: unused import: `Writer` Sep 14 07:34:14.476 INFO kablam! --> src/proto/mod.rs:13:38 Sep 14 07:34:14.476 INFO kablam! | Sep 14 07:34:14.476 INFO kablam! 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Sep 14 07:34:14.476 INFO kablam! | ^^^^^^ Sep 14 07:34:14.476 INFO kablam! Sep 14 07:34:14.476 INFO kablam! warning: unused import: `self::headers::*` Sep 14 07:34:14.476 INFO kablam! --> src/proto/mod.rs:15:5 Sep 14 07:34:14.476 INFO kablam! | Sep 14 07:34:14.476 INFO kablam! 15 | use self::headers::*; Sep 14 07:34:14.476 INFO kablam! | ^^^^^^^^^^^^^^^^ Sep 14 07:34:14.476 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/mqtt_loop.rs:13:5 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.477 INFO kablam! 13 | use take::Take; Sep 14 07:34:14.477 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.477 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused import: `MqttFramedWriter` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/mqtt_loop.rs:21:13 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.477 INFO kablam! 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Sep 14 07:34:14.477 INFO kablam! | ^^^^^^^^^^^^^^^^ Sep 14 07:34:14.477 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused import: `super::response::ResponseProcessor` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/mqtt_loop.rs:23:5 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.477 INFO kablam! 23 | use super::response::ResponseProcessor; Sep 14 07:34:14.477 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.477 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused import: `super::request::RequestProcessor` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/mqtt_loop.rs:24:5 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.477 INFO kablam! 24 | use super::request::RequestProcessor; Sep 14 07:34:14.477 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.477 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:1:16 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.477 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.477 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.477 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:2:28 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.477 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Sep 14 07:34:14.477 INFO kablam! | ^^^^^^^^^ ^^^^ Sep 14 07:34:14.477 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:4:5 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.477 INFO kablam! 4 | use take::Take; Sep 14 07:34:14.477 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.477 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:6:5 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.477 INFO kablam! 6 | use bincode; Sep 14 07:34:14.477 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.477 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:9:25 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.477 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Sep 14 07:34:14.477 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Sep 14 07:34:14.477 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:10:29 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.477 INFO kablam! 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.477 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.477 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused import: `PublishState` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:12:25 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.477 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Sep 14 07:34:14.477 INFO kablam! | ^^^^^^^^^^^^ Sep 14 07:34:14.477 INFO kablam! Sep 14 07:34:14.477 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.477 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:1:16 Sep 14 07:34:14.477 INFO kablam! | Sep 14 07:34:14.478 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.478 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.478 INFO kablam! Sep 14 07:34:14.478 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Sep 14 07:34:14.478 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:2:28 Sep 14 07:34:14.478 INFO kablam! | Sep 14 07:34:14.478 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Sep 14 07:34:14.478 INFO kablam! | ^^^^^^^^^ ^^^^ Sep 14 07:34:14.478 INFO kablam! Sep 14 07:34:14.478 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.478 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:4:5 Sep 14 07:34:14.478 INFO kablam! | Sep 14 07:34:14.478 INFO kablam! 4 | use take::Take; Sep 14 07:34:14.478 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.478 INFO kablam! Sep 14 07:34:14.478 INFO kablam! warning: unused import: `PacketType` Sep 14 07:34:14.478 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:9:25 Sep 14 07:34:14.478 INFO kablam! | Sep 14 07:34:14.478 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Sep 14 07:34:14.478 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.478 INFO kablam! Sep 14 07:34:14.478 INFO kablam! warning: unused import: `OneTimeKey` Sep 14 07:34:14.478 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:12:13 Sep 14 07:34:14.478 INFO kablam! | Sep 14 07:34:14.478 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Sep 14 07:34:14.478 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.478 INFO kablam! Sep 14 07:34:14.478 INFO kablam! warning: unused import: `BoxFuture` Sep 14 07:34:14.478 INFO kablam! --> src/tokio/outbound_handlers/mod.rs:8:27 Sep 14 07:34:14.478 INFO kablam! | Sep 14 07:34:14.478 INFO kablam! 8 | use tokio::{RequestTuple, BoxFuture}; Sep 14 07:34:14.478 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.478 INFO kablam! Sep 14 07:34:14.478 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.478 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Sep 14 07:34:14.478 INFO kablam! | Sep 14 07:34:14.478 INFO kablam! 3 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.478 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.478 INFO kablam! Sep 14 07:34:14.478 INFO kablam! warning: unused import: `AsyncSink` Sep 14 07:34:14.478 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Sep 14 07:34:14.478 INFO kablam! | Sep 14 07:34:14.478 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.478 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.478 INFO kablam! Sep 14 07:34:14.478 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Sep 14 07:34:14.478 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Sep 14 07:34:14.478 INFO kablam! | Sep 14 07:34:14.478 INFO kablam! 6 | use futures::unsync::mpsc::UnboundedSender; Sep 14 07:34:14.478 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.478 INFO kablam! Sep 14 07:34:14.478 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.478 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Sep 14 07:34:14.481 INFO kablam! | Sep 14 07:34:14.481 INFO kablam! 7 | use take::Take; Sep 14 07:34:14.481 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.481 INFO kablam! Sep 14 07:34:14.481 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.481 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Sep 14 07:34:14.481 INFO kablam! | Sep 14 07:34:14.481 INFO kablam! 9 | use bincode; Sep 14 07:34:14.481 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.481 INFO kablam! Sep 14 07:34:14.481 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Sep 14 07:34:14.481 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Sep 14 07:34:14.481 INFO kablam! | Sep 14 07:34:14.481 INFO kablam! 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.481 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.481 INFO kablam! 12 | PacketId, TopicName}; Sep 14 07:34:14.482 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.482 INFO kablam! Sep 14 07:34:14.482 INFO kablam! warning: unused imports: `ResultExt`, `Result` Sep 14 07:34:14.482 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Sep 14 07:34:14.482 INFO kablam! | Sep 14 07:34:14.482 INFO kablam! 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.482 INFO kablam! | ^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.482 INFO kablam! Sep 14 07:34:14.482 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Sep 14 07:34:14.482 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Sep 14 07:34:14.482 INFO kablam! | Sep 14 07:34:14.482 INFO kablam! 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Sep 14 07:34:14.482 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.482 INFO kablam! Sep 14 07:34:14.482 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.482 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Sep 14 07:34:14.482 INFO kablam! | Sep 14 07:34:14.482 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.482 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.482 INFO kablam! Sep 14 07:34:14.482 INFO kablam! warning: unused import: `AsyncSink` Sep 14 07:34:14.482 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Sep 14 07:34:14.483 INFO kablam! | Sep 14 07:34:14.483 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.483 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.483 INFO kablam! Sep 14 07:34:14.483 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.483 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Sep 14 07:34:14.483 INFO kablam! | Sep 14 07:34:14.483 INFO kablam! 6 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.483 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.483 INFO kablam! Sep 14 07:34:14.483 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Sep 14 07:34:14.483 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Sep 14 07:34:14.483 INFO kablam! | Sep 14 07:34:14.483 INFO kablam! 7 | use futures::unsync::mpsc::UnboundedSender; Sep 14 07:34:14.483 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.483 INFO kablam! Sep 14 07:34:14.483 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.483 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Sep 14 07:34:14.483 INFO kablam! | Sep 14 07:34:14.483 INFO kablam! 8 | use take::Take; Sep 14 07:34:14.483 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.483 INFO kablam! Sep 14 07:34:14.483 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.483 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Sep 14 07:34:14.483 INFO kablam! | Sep 14 07:34:14.484 INFO kablam! 10 | use bincode; Sep 14 07:34:14.484 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.484 INFO kablam! Sep 14 07:34:14.484 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Sep 14 07:34:14.484 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Sep 14 07:34:14.484 INFO kablam! | Sep 14 07:34:14.484 INFO kablam! 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.484 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.484 INFO kablam! 13 | PacketId, TopicName}; Sep 14 07:34:14.484 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.484 INFO kablam! Sep 14 07:34:14.484 INFO kablam! warning: unused imports: `ResultExt`, `Result` Sep 14 07:34:14.484 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Sep 14 07:34:14.484 INFO kablam! | Sep 14 07:34:14.484 INFO kablam! 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.484 INFO kablam! | ^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.484 INFO kablam! Sep 14 07:34:14.484 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.484 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Sep 14 07:34:14.484 INFO kablam! | Sep 14 07:34:14.484 INFO kablam! 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Sep 14 07:34:14.484 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.484 INFO kablam! Sep 14 07:34:14.484 INFO kablam! warning: unused import: `std::ops::Deref` Sep 14 07:34:14.485 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:2:5 Sep 14 07:34:14.485 INFO kablam! | Sep 14 07:34:14.485 INFO kablam! 2 | use std::ops::Deref; Sep 14 07:34:14.485 INFO kablam! | ^^^^^^^^^^^^^^^ Sep 14 07:34:14.485 INFO kablam! Sep 14 07:34:14.485 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.485 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:4:16 Sep 14 07:34:14.485 INFO kablam! | Sep 14 07:34:14.485 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.485 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.485 INFO kablam! Sep 14 07:34:14.485 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Sep 14 07:34:14.485 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:15 Sep 14 07:34:14.485 INFO kablam! | Sep 14 07:34:14.485 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.485 INFO kablam! | ^^^^ ^^^^^^^^^ Sep 14 07:34:14.485 INFO kablam! Sep 14 07:34:14.485 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.485 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:7:5 Sep 14 07:34:14.485 INFO kablam! | Sep 14 07:34:14.485 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.485 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.485 INFO kablam! Sep 14 07:34:14.485 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Sep 14 07:34:14.485 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:8:5 Sep 14 07:34:14.486 INFO kablam! | Sep 14 07:34:14.486 INFO kablam! 8 | use futures::unsync::mpsc::UnboundedSender; Sep 14 07:34:14.486 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.486 INFO kablam! Sep 14 07:34:14.486 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.486 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:9:5 Sep 14 07:34:14.486 INFO kablam! | Sep 14 07:34:14.486 INFO kablam! 9 | use take::Take; Sep 14 07:34:14.486 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.486 INFO kablam! Sep 14 07:34:14.486 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.486 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:11:5 Sep 14 07:34:14.486 INFO kablam! | Sep 14 07:34:14.486 INFO kablam! 11 | use bincode; Sep 14 07:34:14.486 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.486 INFO kablam! Sep 14 07:34:14.486 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Sep 14 07:34:14.486 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:13:13 Sep 14 07:34:14.486 INFO kablam! | Sep 14 07:34:14.486 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.486 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.486 INFO kablam! 14 | PacketId, TopicName}; Sep 14 07:34:14.486 INFO kablam! | ^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.486 INFO kablam! Sep 14 07:34:14.487 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Sep 14 07:34:14.487 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:16:21 Sep 14 07:34:14.487 INFO kablam! | Sep 14 07:34:14.487 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.487 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.487 INFO kablam! Sep 14 07:34:14.487 INFO kablam! warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Sep 14 07:34:14.487 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:17:5 Sep 14 07:34:14.487 INFO kablam! | Sep 14 07:34:14.487 INFO kablam! 17 | use errors::proto::ErrorKind as ProtoErrorKind; Sep 14 07:34:14.487 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.487 INFO kablam! Sep 14 07:34:14.491 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.491 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:19:25 Sep 14 07:34:14.491 INFO kablam! | Sep 14 07:34:14.491 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Sep 14 07:34:14.491 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.491 INFO kablam! Sep 14 07:34:14.491 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Sep 14 07:34:14.491 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:1:5 Sep 14 07:34:14.492 INFO kablam! | Sep 14 07:34:14.492 INFO kablam! 1 | use std::collections::hash_map::Entry; Sep 14 07:34:14.492 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.492 INFO kablam! Sep 14 07:34:14.492 INFO kablam! warning: unused import: `std::ops::Deref` Sep 14 07:34:14.492 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:2:5 Sep 14 07:34:14.492 INFO kablam! | Sep 14 07:34:14.492 INFO kablam! 2 | use std::ops::Deref; Sep 14 07:34:14.492 INFO kablam! | ^^^^^^^^^^^^^^^ Sep 14 07:34:14.492 INFO kablam! Sep 14 07:34:14.492 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.492 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:5:16 Sep 14 07:34:14.492 INFO kablam! | Sep 14 07:34:14.492 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.492 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.492 INFO kablam! Sep 14 07:34:14.492 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Sep 14 07:34:14.492 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:28 Sep 14 07:34:14.492 INFO kablam! | Sep 14 07:34:14.492 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.492 INFO kablam! | ^^^^^^^^^ ^^^^ Sep 14 07:34:14.492 INFO kablam! Sep 14 07:34:14.492 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.492 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:7:5 Sep 14 07:34:14.492 INFO kablam! | Sep 14 07:34:14.492 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.492 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.492 INFO kablam! Sep 14 07:34:14.492 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.493 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:9:5 Sep 14 07:34:14.493 INFO kablam! | Sep 14 07:34:14.493 INFO kablam! 9 | use take::Take; Sep 14 07:34:14.493 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.493 INFO kablam! Sep 14 07:34:14.493 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.493 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:11:5 Sep 14 07:34:14.493 INFO kablam! | Sep 14 07:34:14.493 INFO kablam! 11 | use bincode; Sep 14 07:34:14.493 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.493 INFO kablam! Sep 14 07:34:14.493 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Sep 14 07:34:14.493 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:13:25 Sep 14 07:34:14.493 INFO kablam! | Sep 14 07:34:14.493 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.493 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.493 INFO kablam! Sep 14 07:34:14.493 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Sep 14 07:34:14.493 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:16:21 Sep 14 07:34:14.493 INFO kablam! | Sep 14 07:34:14.493 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.493 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.493 INFO kablam! Sep 14 07:34:14.493 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.493 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:19:13 Sep 14 07:34:14.493 INFO kablam! | Sep 14 07:34:14.493 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Sep 14 07:34:14.494 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.494 INFO kablam! Sep 14 07:34:14.494 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Sep 14 07:34:14.494 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Sep 14 07:34:14.494 INFO kablam! | Sep 14 07:34:14.494 INFO kablam! 1 | use std::collections::hash_map::Entry; Sep 14 07:34:14.494 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.494 INFO kablam! Sep 14 07:34:14.494 INFO kablam! warning: unused import: `std::ops::Deref` Sep 14 07:34:14.494 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Sep 14 07:34:14.494 INFO kablam! | Sep 14 07:34:14.494 INFO kablam! 2 | use std::ops::Deref; Sep 14 07:34:14.494 INFO kablam! | ^^^^^^^^^^^^^^^ Sep 14 07:34:14.494 INFO kablam! Sep 14 07:34:14.494 INFO kablam! warning: unused import: `bytes::Bytes` Sep 14 07:34:14.494 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Sep 14 07:34:14.494 INFO kablam! | Sep 14 07:34:14.494 INFO kablam! 4 | use bytes::Bytes; Sep 14 07:34:14.494 INFO kablam! | ^^^^^^^^^^^^ Sep 14 07:34:14.494 INFO kablam! Sep 14 07:34:14.494 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.494 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Sep 14 07:34:14.494 INFO kablam! | Sep 14 07:34:14.494 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.494 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.494 INFO kablam! Sep 14 07:34:14.494 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Sep 14 07:34:14.494 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Sep 14 07:34:14.495 INFO kablam! | Sep 14 07:34:14.495 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.495 INFO kablam! | ^^^^ ^^^^^^^^^ Sep 14 07:34:14.495 INFO kablam! Sep 14 07:34:14.495 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.495 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Sep 14 07:34:14.495 INFO kablam! | Sep 14 07:34:14.495 INFO kablam! 8 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.495 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.495 INFO kablam! Sep 14 07:34:14.495 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Sep 14 07:34:14.495 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Sep 14 07:34:14.495 INFO kablam! | Sep 14 07:34:14.495 INFO kablam! 9 | use futures::unsync::mpsc::UnboundedSender; Sep 14 07:34:14.495 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.495 INFO kablam! Sep 14 07:34:14.495 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.495 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Sep 14 07:34:14.495 INFO kablam! | Sep 14 07:34:14.495 INFO kablam! 10 | use take::Take; Sep 14 07:34:14.495 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.495 INFO kablam! Sep 14 07:34:14.495 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.495 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Sep 14 07:34:14.496 INFO kablam! | Sep 14 07:34:14.496 INFO kablam! 12 | use bincode; Sep 14 07:34:14.496 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.496 INFO kablam! Sep 14 07:34:14.496 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Sep 14 07:34:14.496 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Sep 14 07:34:14.496 INFO kablam! | Sep 14 07:34:14.496 INFO kablam! 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.496 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.496 INFO kablam! 15 | PacketId, TopicName}; Sep 14 07:34:14.496 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.496 INFO kablam! Sep 14 07:34:14.496 INFO kablam! warning: unused import: `Result` Sep 14 07:34:14.496 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Sep 14 07:34:14.496 INFO kablam! | Sep 14 07:34:14.496 INFO kablam! 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.496 INFO kablam! | ^^^^^^ Sep 14 07:34:14.496 INFO kablam! Sep 14 07:34:14.496 INFO kablam! warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.496 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Sep 14 07:34:14.496 INFO kablam! | Sep 14 07:34:14.496 INFO kablam! 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Sep 14 07:34:14.496 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.496 INFO kablam! Sep 14 07:34:14.496 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Sep 14 07:34:14.496 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Sep 14 07:34:14.496 INFO kablam! | Sep 14 07:34:14.497 INFO kablam! 1 | use std::collections::hash_map::Entry; Sep 14 07:34:14.497 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.497 INFO kablam! Sep 14 07:34:14.497 INFO kablam! warning: unused import: `std::ops::Deref` Sep 14 07:34:14.497 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Sep 14 07:34:14.497 INFO kablam! | Sep 14 07:34:14.497 INFO kablam! 2 | use std::ops::Deref; Sep 14 07:34:14.497 INFO kablam! | ^^^^^^^^^^^^^^^ Sep 14 07:34:14.497 INFO kablam! Sep 14 07:34:14.497 INFO kablam! warning: unused import: `bytes::Bytes` Sep 14 07:34:14.497 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Sep 14 07:34:14.497 INFO kablam! | Sep 14 07:34:14.497 INFO kablam! 4 | use bytes::Bytes; Sep 14 07:34:14.497 INFO kablam! | ^^^^^^^^^^^^ Sep 14 07:34:14.497 INFO kablam! Sep 14 07:34:14.497 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.497 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Sep 14 07:34:14.497 INFO kablam! | Sep 14 07:34:14.497 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.497 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.497 INFO kablam! Sep 14 07:34:14.497 INFO kablam! warning: unused import: `AsyncSink` Sep 14 07:34:14.497 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Sep 14 07:34:14.497 INFO kablam! | Sep 14 07:34:14.497 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.498 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.498 INFO kablam! Sep 14 07:34:14.498 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.498 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Sep 14 07:34:14.498 INFO kablam! | Sep 14 07:34:14.498 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.498 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.498 INFO kablam! Sep 14 07:34:14.498 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.498 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Sep 14 07:34:14.498 INFO kablam! | Sep 14 07:34:14.498 INFO kablam! 9 | use take::Take; Sep 14 07:34:14.498 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.498 INFO kablam! Sep 14 07:34:14.498 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Sep 14 07:34:14.498 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Sep 14 07:34:14.498 INFO kablam! | Sep 14 07:34:14.498 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.498 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.499 INFO kablam! 14 | PacketId, TopicName}; Sep 14 07:34:14.499 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.499 INFO kablam! Sep 14 07:34:14.499 INFO kablam! warning: unused import: `Result` Sep 14 07:34:14.499 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Sep 14 07:34:14.499 INFO kablam! | Sep 14 07:34:14.499 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.499 INFO kablam! | ^^^^^^ Sep 14 07:34:14.499 INFO kablam! Sep 14 07:34:14.499 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.499 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Sep 14 07:34:14.499 INFO kablam! | Sep 14 07:34:14.499 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Sep 14 07:34:14.499 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.499 INFO kablam! Sep 14 07:34:14.499 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Sep 14 07:34:14.499 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:1:5 Sep 14 07:34:14.499 INFO kablam! | Sep 14 07:34:14.499 INFO kablam! 1 | use std::collections::hash_map::Entry; Sep 14 07:34:14.500 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.500 INFO kablam! Sep 14 07:34:14.500 INFO kablam! warning: unused import: `std::ops::Deref` Sep 14 07:34:14.500 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:2:5 Sep 14 07:34:14.500 INFO kablam! | Sep 14 07:34:14.500 INFO kablam! 2 | use std::ops::Deref; Sep 14 07:34:14.503 INFO kablam! | ^^^^^^^^^^^^^^^ Sep 14 07:34:14.503 INFO kablam! Sep 14 07:34:14.503 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.503 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:5:16 Sep 14 07:34:14.503 INFO kablam! | Sep 14 07:34:14.503 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.504 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.504 INFO kablam! Sep 14 07:34:14.504 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Sep 14 07:34:14.504 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:28 Sep 14 07:34:14.504 INFO kablam! | Sep 14 07:34:14.504 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.504 INFO kablam! | ^^^^^^^^^ ^^^^ Sep 14 07:34:14.504 INFO kablam! Sep 14 07:34:14.504 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.504 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:7:5 Sep 14 07:34:14.504 INFO kablam! | Sep 14 07:34:14.504 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.504 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.504 INFO kablam! Sep 14 07:34:14.504 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.504 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:9:5 Sep 14 07:34:14.504 INFO kablam! | Sep 14 07:34:14.504 INFO kablam! 9 | use take::Take; Sep 14 07:34:14.504 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.504 INFO kablam! Sep 14 07:34:14.504 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.504 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:11:5 Sep 14 07:34:14.505 INFO kablam! | Sep 14 07:34:14.505 INFO kablam! 11 | use bincode; Sep 14 07:34:14.505 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.505 INFO kablam! Sep 14 07:34:14.505 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Sep 14 07:34:14.505 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:13:25 Sep 14 07:34:14.505 INFO kablam! | Sep 14 07:34:14.505 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.505 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.505 INFO kablam! Sep 14 07:34:14.505 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Sep 14 07:34:14.505 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:16:21 Sep 14 07:34:14.505 INFO kablam! | Sep 14 07:34:14.505 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.505 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.505 INFO kablam! Sep 14 07:34:14.505 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.505 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:19:13 Sep 14 07:34:14.505 INFO kablam! | Sep 14 07:34:14.505 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Sep 14 07:34:14.505 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.505 INFO kablam! Sep 14 07:34:14.505 INFO kablam! warning: unused import: `Error` Sep 14 07:34:14.505 INFO kablam! --> src/proto/types.rs:4:14 Sep 14 07:34:14.505 INFO kablam! | Sep 14 07:34:14.506 INFO kablam! 4 | use errors::{Error, ErrorKind}; Sep 14 07:34:14.506 INFO kablam! | ^^^^^ Sep 14 07:34:14.506 INFO kablam! | Sep 14 07:34:14.506 INFO kablam! = note: #[warn(unused_imports)] on by default Sep 14 07:34:14.506 INFO kablam! Sep 14 07:34:14.506 INFO kablam! warning: unused import: `linked_hash_map::LinkedHashMap` Sep 14 07:34:14.506 INFO kablam! --> src/proto/types.rs:5:5 Sep 14 07:34:14.506 INFO kablam! | Sep 14 07:34:14.506 INFO kablam! 5 | use linked_hash_map::LinkedHashMap; Sep 14 07:34:14.506 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.506 INFO kablam! Sep 14 07:34:14.506 INFO kablam! warning: unused imports: `IResult`, `be_u16` Sep 14 07:34:14.506 INFO kablam! --> src/proto/headers.rs:3:11 Sep 14 07:34:14.506 INFO kablam! | Sep 14 07:34:14.506 INFO kablam! 3 | use nom::{IResult, be_u16}; Sep 14 07:34:14.506 INFO kablam! | ^^^^^^^ ^^^^^^ Sep 14 07:34:14.506 INFO kablam! Sep 14 07:34:14.506 INFO kablam! warning: unused import: `std::io` Sep 14 07:34:14.506 INFO kablam! --> src/proto/mod.rs:8:5 Sep 14 07:34:14.506 INFO kablam! | Sep 14 07:34:14.506 INFO kablam! 8 | use std::io; Sep 14 07:34:14.506 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.506 INFO kablam! Sep 14 07:34:14.506 INFO kablam! warning: unused import: `Entry` Sep 14 07:34:14.506 INFO kablam! --> src/proto/mod.rs:12:23 Sep 14 07:34:14.506 INFO kablam! | Sep 14 07:34:14.507 INFO kablam! 12 | use linked_hash_map::{Entry,LinkedHashMap}; Sep 14 07:34:14.507 INFO kablam! | ^^^^^ Sep 14 07:34:14.507 INFO kablam! Sep 14 07:34:14.507 INFO kablam! warning: unused import: `Writer` Sep 14 07:34:14.507 INFO kablam! --> src/proto/mod.rs:13:38 Sep 14 07:34:14.507 INFO kablam! | Sep 14 07:34:14.507 INFO kablam! 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Sep 14 07:34:14.507 INFO kablam! | ^^^^^^ Sep 14 07:34:14.507 INFO kablam! Sep 14 07:34:14.507 INFO kablam! warning: unused import: `self::headers::*` Sep 14 07:34:14.507 INFO kablam! --> src/proto/mod.rs:15:5 Sep 14 07:34:14.507 INFO kablam! | Sep 14 07:34:14.507 INFO kablam! 15 | use self::headers::*; Sep 14 07:34:14.507 INFO kablam! | ^^^^^^^^^^^^^^^^ Sep 14 07:34:14.507 INFO kablam! Sep 14 07:34:14.507 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.507 INFO kablam! --> src/tokio/mqtt_loop.rs:13:5 Sep 14 07:34:14.507 INFO kablam! | Sep 14 07:34:14.507 INFO kablam! 13 | use take::Take; Sep 14 07:34:14.507 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.507 INFO kablam! Sep 14 07:34:14.507 INFO kablam! warning: unused import: `MqttFramedWriter` Sep 14 07:34:14.507 INFO kablam! --> src/tokio/mqtt_loop.rs:21:13 Sep 14 07:34:14.507 INFO kablam! | Sep 14 07:34:14.507 INFO kablam! 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Sep 14 07:34:14.508 INFO kablam! | ^^^^^^^^^^^^^^^^ Sep 14 07:34:14.508 INFO kablam! Sep 14 07:34:14.508 INFO kablam! warning: unused import: `super::response::ResponseProcessor` Sep 14 07:34:14.508 INFO kablam! --> src/tokio/mqtt_loop.rs:23:5 Sep 14 07:34:14.508 INFO kablam! | Sep 14 07:34:14.508 INFO kablam! 23 | use super::response::ResponseProcessor; Sep 14 07:34:14.508 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.508 INFO kablam! Sep 14 07:34:14.508 INFO kablam! warning: unused import: `super::request::RequestProcessor` Sep 14 07:34:14.508 INFO kablam! --> src/tokio/mqtt_loop.rs:24:5 Sep 14 07:34:14.508 INFO kablam! | Sep 14 07:34:14.508 INFO kablam! 24 | use super::request::RequestProcessor; Sep 14 07:34:14.508 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.508 INFO kablam! Sep 14 07:34:14.508 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.508 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:1:16 Sep 14 07:34:14.508 INFO kablam! | Sep 14 07:34:14.508 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.508 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.508 INFO kablam! Sep 14 07:34:14.508 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Sep 14 07:34:14.509 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:2:28 Sep 14 07:34:14.509 INFO kablam! | Sep 14 07:34:14.509 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Sep 14 07:34:14.509 INFO kablam! | ^^^^^^^^^ ^^^^ Sep 14 07:34:14.509 INFO kablam! Sep 14 07:34:14.509 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.509 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:4:5 Sep 14 07:34:14.509 INFO kablam! | Sep 14 07:34:14.509 INFO kablam! 4 | use take::Take; Sep 14 07:34:14.509 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.509 INFO kablam! Sep 14 07:34:14.509 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.509 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:6:5 Sep 14 07:34:14.509 INFO kablam! | Sep 14 07:34:14.509 INFO kablam! 6 | use bincode; Sep 14 07:34:14.509 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.509 INFO kablam! Sep 14 07:34:14.509 INFO kablam! warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Sep 14 07:34:14.509 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:9:25 Sep 14 07:34:14.509 INFO kablam! | Sep 14 07:34:14.509 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Sep 14 07:34:14.509 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Sep 14 07:34:14.509 INFO kablam! Sep 14 07:34:14.509 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt` Sep 14 07:34:14.509 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:10:29 Sep 14 07:34:14.509 INFO kablam! | Sep 14 07:34:14.509 INFO kablam! 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.510 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.510 INFO kablam! Sep 14 07:34:14.510 INFO kablam! warning: unused import: `PublishState` Sep 14 07:34:14.510 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:12:25 Sep 14 07:34:14.510 INFO kablam! | Sep 14 07:34:14.510 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Sep 14 07:34:14.510 INFO kablam! | ^^^^^^^^^^^^ Sep 14 07:34:14.510 INFO kablam! Sep 14 07:34:14.510 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.510 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:1:16 Sep 14 07:34:14.510 INFO kablam! | Sep 14 07:34:14.510 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.514 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.515 INFO kablam! Sep 14 07:34:14.515 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Sep 14 07:34:14.515 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:2:28 Sep 14 07:34:14.515 INFO kablam! | Sep 14 07:34:14.515 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Sep 14 07:34:14.515 INFO kablam! | ^^^^^^^^^ ^^^^ Sep 14 07:34:14.515 INFO kablam! Sep 14 07:34:14.515 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.515 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:4:5 Sep 14 07:34:14.515 INFO kablam! | Sep 14 07:34:14.515 INFO kablam! 4 | use take::Take; Sep 14 07:34:14.515 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.515 INFO kablam! Sep 14 07:34:14.515 INFO kablam! warning: unused import: `PacketType` Sep 14 07:34:14.515 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:9:25 Sep 14 07:34:14.515 INFO kablam! | Sep 14 07:34:14.515 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Sep 14 07:34:14.515 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.515 INFO kablam! Sep 14 07:34:14.515 INFO kablam! warning: unused import: `OneTimeKey` Sep 14 07:34:14.515 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:12:13 Sep 14 07:34:14.515 INFO kablam! | Sep 14 07:34:14.515 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Sep 14 07:34:14.515 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.515 INFO kablam! Sep 14 07:34:14.516 INFO kablam! warning: unused import: `BoxFuture` Sep 14 07:34:14.516 INFO kablam! --> src/tokio/outbound_handlers/mod.rs:8:27 Sep 14 07:34:14.516 INFO kablam! | Sep 14 07:34:14.516 INFO kablam! 8 | use tokio::{RequestTuple, BoxFuture}; Sep 14 07:34:14.516 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.516 INFO kablam! Sep 14 07:34:14.516 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.516 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Sep 14 07:34:14.516 INFO kablam! | Sep 14 07:34:14.516 INFO kablam! 3 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.516 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.516 INFO kablam! Sep 14 07:34:14.516 INFO kablam! warning: unused import: `AsyncSink` Sep 14 07:34:14.516 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Sep 14 07:34:14.516 INFO kablam! | Sep 14 07:34:14.516 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.516 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.516 INFO kablam! Sep 14 07:34:14.516 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Sep 14 07:34:14.516 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Sep 14 07:34:14.516 INFO kablam! | Sep 14 07:34:14.517 INFO kablam! 6 | use futures::unsync::mpsc::UnboundedSender; Sep 14 07:34:14.517 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.517 INFO kablam! Sep 14 07:34:14.517 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.517 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Sep 14 07:34:14.517 INFO kablam! | Sep 14 07:34:14.517 INFO kablam! 7 | use take::Take; Sep 14 07:34:14.517 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.517 INFO kablam! Sep 14 07:34:14.517 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.517 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Sep 14 07:34:14.517 INFO kablam! | Sep 14 07:34:14.517 INFO kablam! 9 | use bincode; Sep 14 07:34:14.517 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.517 INFO kablam! Sep 14 07:34:14.517 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Sep 14 07:34:14.517 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Sep 14 07:34:14.517 INFO kablam! | Sep 14 07:34:14.517 INFO kablam! 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.517 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.517 INFO kablam! 12 | PacketId, TopicName}; Sep 14 07:34:14.517 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.517 INFO kablam! Sep 14 07:34:14.517 INFO kablam! warning: unused imports: `ResultExt`, `Result` Sep 14 07:34:14.517 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Sep 14 07:34:14.517 INFO kablam! | Sep 14 07:34:14.517 INFO kablam! 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.517 INFO kablam! | ^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.518 INFO kablam! Sep 14 07:34:14.518 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Sep 14 07:34:14.518 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Sep 14 07:34:14.518 INFO kablam! | Sep 14 07:34:14.518 INFO kablam! 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Sep 14 07:34:14.518 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.518 INFO kablam! Sep 14 07:34:14.518 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.518 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Sep 14 07:34:14.518 INFO kablam! | Sep 14 07:34:14.518 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.518 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.518 INFO kablam! Sep 14 07:34:14.518 INFO kablam! warning: unused import: `AsyncSink` Sep 14 07:34:14.518 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Sep 14 07:34:14.518 INFO kablam! | Sep 14 07:34:14.518 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.518 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.518 INFO kablam! Sep 14 07:34:14.518 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.518 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Sep 14 07:34:14.518 INFO kablam! | Sep 14 07:34:14.518 INFO kablam! 6 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.518 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.518 INFO kablam! Sep 14 07:34:14.518 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Sep 14 07:34:14.518 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Sep 14 07:34:14.519 INFO kablam! | Sep 14 07:34:14.519 INFO kablam! 7 | use futures::unsync::mpsc::UnboundedSender; Sep 14 07:34:14.519 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.519 INFO kablam! Sep 14 07:34:14.519 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.519 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Sep 14 07:34:14.519 INFO kablam! | Sep 14 07:34:14.519 INFO kablam! 8 | use take::Take; Sep 14 07:34:14.519 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.519 INFO kablam! Sep 14 07:34:14.519 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.519 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Sep 14 07:34:14.519 INFO kablam! | Sep 14 07:34:14.519 INFO kablam! 10 | use bincode; Sep 14 07:34:14.519 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.519 INFO kablam! Sep 14 07:34:14.519 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Sep 14 07:34:14.519 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Sep 14 07:34:14.519 INFO kablam! | Sep 14 07:34:14.519 INFO kablam! 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.519 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.519 INFO kablam! 13 | PacketId, TopicName}; Sep 14 07:34:14.519 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.519 INFO kablam! Sep 14 07:34:14.519 INFO kablam! warning: unused imports: `ResultExt`, `Result` Sep 14 07:34:14.519 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Sep 14 07:34:14.519 INFO kablam! | Sep 14 07:34:14.519 INFO kablam! 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.519 INFO kablam! | ^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.520 INFO kablam! Sep 14 07:34:14.520 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.520 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Sep 14 07:34:14.520 INFO kablam! | Sep 14 07:34:14.520 INFO kablam! 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Sep 14 07:34:14.520 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.520 INFO kablam! Sep 14 07:34:14.520 INFO kablam! warning: unused import: `std::ops::Deref` Sep 14 07:34:14.520 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:2:5 Sep 14 07:34:14.520 INFO kablam! | Sep 14 07:34:14.520 INFO kablam! 2 | use std::ops::Deref; Sep 14 07:34:14.520 INFO kablam! | ^^^^^^^^^^^^^^^ Sep 14 07:34:14.520 INFO kablam! Sep 14 07:34:14.520 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.520 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:4:16 Sep 14 07:34:14.520 INFO kablam! | Sep 14 07:34:14.520 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.520 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.520 INFO kablam! Sep 14 07:34:14.520 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Sep 14 07:34:14.520 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:15 Sep 14 07:34:14.520 INFO kablam! | Sep 14 07:34:14.520 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.520 INFO kablam! | ^^^^ ^^^^^^^^^ Sep 14 07:34:14.520 INFO kablam! Sep 14 07:34:14.521 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.521 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:7:5 Sep 14 07:34:14.521 INFO kablam! | Sep 14 07:34:14.521 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.521 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.521 INFO kablam! Sep 14 07:34:14.521 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Sep 14 07:34:14.521 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:8:5 Sep 14 07:34:14.521 INFO kablam! | Sep 14 07:34:14.521 INFO kablam! 8 | use futures::unsync::mpsc::UnboundedSender; Sep 14 07:34:14.521 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.521 INFO kablam! Sep 14 07:34:14.521 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.521 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:9:5 Sep 14 07:34:14.521 INFO kablam! | Sep 14 07:34:14.521 INFO kablam! 9 | use take::Take; Sep 14 07:34:14.521 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.521 INFO kablam! Sep 14 07:34:14.521 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.521 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:11:5 Sep 14 07:34:14.521 INFO kablam! | Sep 14 07:34:14.521 INFO kablam! 11 | use bincode; Sep 14 07:34:14.521 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.521 INFO kablam! Sep 14 07:34:14.521 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Sep 14 07:34:14.521 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:13:13 Sep 14 07:34:14.521 INFO kablam! | Sep 14 07:34:14.521 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.521 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.522 INFO kablam! 14 | PacketId, TopicName}; Sep 14 07:34:14.522 INFO kablam! | ^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.522 INFO kablam! Sep 14 07:34:14.522 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Sep 14 07:34:14.522 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:16:21 Sep 14 07:34:14.522 INFO kablam! | Sep 14 07:34:14.522 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.522 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.522 INFO kablam! Sep 14 07:34:14.522 INFO kablam! warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Sep 14 07:34:14.522 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:17:5 Sep 14 07:34:14.522 INFO kablam! | Sep 14 07:34:14.522 INFO kablam! 17 | use errors::proto::ErrorKind as ProtoErrorKind; Sep 14 07:34:14.522 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.522 INFO kablam! Sep 14 07:34:14.522 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.522 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:19:25 Sep 14 07:34:14.522 INFO kablam! | Sep 14 07:34:14.522 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Sep 14 07:34:14.522 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.522 INFO kablam! Sep 14 07:34:14.522 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Sep 14 07:34:14.522 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:1:5 Sep 14 07:34:14.522 INFO kablam! | Sep 14 07:34:14.522 INFO kablam! 1 | use std::collections::hash_map::Entry; Sep 14 07:34:14.523 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.523 INFO kablam! Sep 14 07:34:14.523 INFO kablam! warning: unused import: `std::ops::Deref` Sep 14 07:34:14.523 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:2:5 Sep 14 07:34:14.523 INFO kablam! | Sep 14 07:34:14.523 INFO kablam! 2 | use std::ops::Deref; Sep 14 07:34:14.523 INFO kablam! | ^^^^^^^^^^^^^^^ Sep 14 07:34:14.523 INFO kablam! Sep 14 07:34:14.523 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.523 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:5:16 Sep 14 07:34:14.523 INFO kablam! | Sep 14 07:34:14.523 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.523 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.523 INFO kablam! Sep 14 07:34:14.523 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Sep 14 07:34:14.523 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:28 Sep 14 07:34:14.523 INFO kablam! | Sep 14 07:34:14.523 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.523 INFO kablam! | ^^^^^^^^^ ^^^^ Sep 14 07:34:14.523 INFO kablam! Sep 14 07:34:14.523 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.523 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:7:5 Sep 14 07:34:14.523 INFO kablam! | Sep 14 07:34:14.523 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.523 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.523 INFO kablam! Sep 14 07:34:14.523 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.523 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:9:5 Sep 14 07:34:14.524 INFO kablam! | Sep 14 07:34:14.524 INFO kablam! 9 | use take::Take; Sep 14 07:34:14.524 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.524 INFO kablam! Sep 14 07:34:14.524 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.524 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:11:5 Sep 14 07:34:14.524 INFO kablam! | Sep 14 07:34:14.524 INFO kablam! 11 | use bincode; Sep 14 07:34:14.524 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.524 INFO kablam! Sep 14 07:34:14.524 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Sep 14 07:34:14.524 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:13:25 Sep 14 07:34:14.524 INFO kablam! | Sep 14 07:34:14.524 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.524 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.524 INFO kablam! Sep 14 07:34:14.524 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Sep 14 07:34:14.524 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:16:21 Sep 14 07:34:14.524 INFO kablam! | Sep 14 07:34:14.524 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.524 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.524 INFO kablam! Sep 14 07:34:14.524 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.524 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:19:13 Sep 14 07:34:14.524 INFO kablam! | Sep 14 07:34:14.524 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Sep 14 07:34:14.525 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.525 INFO kablam! Sep 14 07:34:14.525 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Sep 14 07:34:14.525 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Sep 14 07:34:14.525 INFO kablam! | Sep 14 07:34:14.525 INFO kablam! 1 | use std::collections::hash_map::Entry; Sep 14 07:34:14.525 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.525 INFO kablam! Sep 14 07:34:14.525 INFO kablam! warning: unused import: `std::ops::Deref` Sep 14 07:34:14.525 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Sep 14 07:34:14.525 INFO kablam! | Sep 14 07:34:14.525 INFO kablam! 2 | use std::ops::Deref; Sep 14 07:34:14.525 INFO kablam! | ^^^^^^^^^^^^^^^ Sep 14 07:34:14.525 INFO kablam! Sep 14 07:34:14.525 INFO kablam! warning: unused import: `bytes::Bytes` Sep 14 07:34:14.525 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Sep 14 07:34:14.525 INFO kablam! | Sep 14 07:34:14.525 INFO kablam! 4 | use bytes::Bytes; Sep 14 07:34:14.525 INFO kablam! | ^^^^^^^^^^^^ Sep 14 07:34:14.525 INFO kablam! Sep 14 07:34:14.525 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.525 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Sep 14 07:34:14.525 INFO kablam! | Sep 14 07:34:14.525 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.525 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.525 INFO kablam! Sep 14 07:34:14.525 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Sep 14 07:34:14.525 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Sep 14 07:34:14.526 INFO kablam! | Sep 14 07:34:14.526 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.530 INFO kablam! | ^^^^ ^^^^^^^^^ Sep 14 07:34:14.531 INFO kablam! Sep 14 07:34:14.531 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.531 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Sep 14 07:34:14.531 INFO kablam! | Sep 14 07:34:14.531 INFO kablam! 8 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.531 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.531 INFO kablam! Sep 14 07:34:14.531 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Sep 14 07:34:14.531 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Sep 14 07:34:14.531 INFO kablam! | Sep 14 07:34:14.531 INFO kablam! 9 | use futures::unsync::mpsc::UnboundedSender; Sep 14 07:34:14.531 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.531 INFO kablam! Sep 14 07:34:14.531 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.531 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Sep 14 07:34:14.531 INFO kablam! | Sep 14 07:34:14.531 INFO kablam! 10 | use take::Take; Sep 14 07:34:14.531 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.531 INFO kablam! Sep 14 07:34:14.531 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.531 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Sep 14 07:34:14.531 INFO kablam! | Sep 14 07:34:14.532 INFO kablam! 12 | use bincode; Sep 14 07:34:14.532 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.532 INFO kablam! Sep 14 07:34:14.532 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Sep 14 07:34:14.532 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Sep 14 07:34:14.532 INFO kablam! | Sep 14 07:34:14.532 INFO kablam! 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.532 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.532 INFO kablam! 15 | PacketId, TopicName}; Sep 14 07:34:14.532 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.532 INFO kablam! Sep 14 07:34:14.532 INFO kablam! warning: unused import: `Result` Sep 14 07:34:14.532 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Sep 14 07:34:14.532 INFO kablam! | Sep 14 07:34:14.532 INFO kablam! 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.532 INFO kablam! | ^^^^^^ Sep 14 07:34:14.532 INFO kablam! Sep 14 07:34:14.532 INFO kablam! warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.532 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Sep 14 07:34:14.532 INFO kablam! | Sep 14 07:34:14.532 INFO kablam! 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Sep 14 07:34:14.532 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.532 INFO kablam! Sep 14 07:34:14.532 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Sep 14 07:34:14.532 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Sep 14 07:34:14.532 INFO kablam! | Sep 14 07:34:14.533 INFO kablam! 1 | use std::collections::hash_map::Entry; Sep 14 07:34:14.533 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.533 INFO kablam! Sep 14 07:34:14.533 INFO kablam! warning: unused import: `std::ops::Deref` Sep 14 07:34:14.533 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Sep 14 07:34:14.533 INFO kablam! | Sep 14 07:34:14.533 INFO kablam! 2 | use std::ops::Deref; Sep 14 07:34:14.533 INFO kablam! | ^^^^^^^^^^^^^^^ Sep 14 07:34:14.533 INFO kablam! Sep 14 07:34:14.533 INFO kablam! warning: unused import: `bytes::Bytes` Sep 14 07:34:14.533 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Sep 14 07:34:14.533 INFO kablam! | Sep 14 07:34:14.533 INFO kablam! 4 | use bytes::Bytes; Sep 14 07:34:14.533 INFO kablam! | ^^^^^^^^^^^^ Sep 14 07:34:14.533 INFO kablam! Sep 14 07:34:14.533 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.533 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Sep 14 07:34:14.533 INFO kablam! | Sep 14 07:34:14.533 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.533 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.533 INFO kablam! Sep 14 07:34:14.533 INFO kablam! warning: unused import: `AsyncSink` Sep 14 07:34:14.533 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Sep 14 07:34:14.533 INFO kablam! | Sep 14 07:34:14.533 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.533 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.534 INFO kablam! Sep 14 07:34:14.534 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.534 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Sep 14 07:34:14.534 INFO kablam! | Sep 14 07:34:14.534 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.534 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.534 INFO kablam! Sep 14 07:34:14.534 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.534 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Sep 14 07:34:14.534 INFO kablam! | Sep 14 07:34:14.534 INFO kablam! 9 | use take::Take; Sep 14 07:34:14.534 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.534 INFO kablam! Sep 14 07:34:14.534 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Sep 14 07:34:14.534 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Sep 14 07:34:14.534 INFO kablam! | Sep 14 07:34:14.534 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.534 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.534 INFO kablam! 14 | PacketId, TopicName}; Sep 14 07:34:14.534 INFO kablam! | ^^^^^^^^^ Sep 14 07:34:14.534 INFO kablam! Sep 14 07:34:14.534 INFO kablam! warning: unused import: `Result` Sep 14 07:34:14.534 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Sep 14 07:34:14.534 INFO kablam! | Sep 14 07:34:14.535 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.535 INFO kablam! | ^^^^^^ Sep 14 07:34:14.535 INFO kablam! Sep 14 07:34:14.535 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.535 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Sep 14 07:34:14.535 INFO kablam! | Sep 14 07:34:14.535 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Sep 14 07:34:14.535 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.535 INFO kablam! Sep 14 07:34:14.535 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Sep 14 07:34:14.535 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:1:5 Sep 14 07:34:14.535 INFO kablam! | Sep 14 07:34:14.535 INFO kablam! 1 | use std::collections::hash_map::Entry; Sep 14 07:34:14.535 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.535 INFO kablam! Sep 14 07:34:14.535 INFO kablam! warning: unused import: `std::ops::Deref` Sep 14 07:34:14.535 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:2:5 Sep 14 07:34:14.535 INFO kablam! | Sep 14 07:34:14.535 INFO kablam! 2 | use std::ops::Deref; Sep 14 07:34:14.535 INFO kablam! | ^^^^^^^^^^^^^^^ Sep 14 07:34:14.535 INFO kablam! Sep 14 07:34:14.535 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Sep 14 07:34:14.535 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:5:16 Sep 14 07:34:14.535 INFO kablam! | Sep 14 07:34:14.535 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Sep 14 07:34:14.535 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Sep 14 07:34:14.535 INFO kablam! Sep 14 07:34:14.535 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Sep 14 07:34:14.535 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:28 Sep 14 07:34:14.535 INFO kablam! | Sep 14 07:34:14.535 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:14.535 INFO kablam! | ^^^^^^^^^ ^^^^ Sep 14 07:34:14.535 INFO kablam! Sep 14 07:34:14.535 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Sep 14 07:34:14.535 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:7:5 Sep 14 07:34:14.535 INFO kablam! | Sep 14 07:34:14.535 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Sep 14 07:34:14.535 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.535 INFO kablam! Sep 14 07:34:14.535 INFO kablam! warning: unused import: `take::Take` Sep 14 07:34:14.535 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:9:5 Sep 14 07:34:14.535 INFO kablam! | Sep 14 07:34:14.535 INFO kablam! 9 | use take::Take; Sep 14 07:34:14.535 INFO kablam! | ^^^^^^^^^^ Sep 14 07:34:14.535 INFO kablam! Sep 14 07:34:14.535 INFO kablam! warning: unused import: `bincode` Sep 14 07:34:14.535 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:11:5 Sep 14 07:34:14.535 INFO kablam! | Sep 14 07:34:14.535 INFO kablam! 11 | use bincode; Sep 14 07:34:14.535 INFO kablam! | ^^^^^^^ Sep 14 07:34:14.535 INFO kablam! Sep 14 07:34:14.535 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Sep 14 07:34:14.535 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:13:25 Sep 14 07:34:14.535 INFO kablam! | Sep 14 07:34:14.535 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Sep 14 07:34:14.535 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Sep 14 07:34:14.535 INFO kablam! Sep 14 07:34:14.535 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Sep 14 07:34:14.535 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:16:21 Sep 14 07:34:14.535 INFO kablam! | Sep 14 07:34:14.535 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Sep 14 07:34:14.536 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.536 INFO kablam! Sep 14 07:34:14.536 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Sep 14 07:34:14.536 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:19:13 Sep 14 07:34:14.536 INFO kablam! | Sep 14 07:34:14.536 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Sep 14 07:34:14.536 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Sep 14 07:34:14.536 INFO kablam! Sep 14 07:34:14.587 INFO kablam! 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 Sep 14 07:34:14.587 INFO kablam! --> src/types.rs:3:5 Sep 14 07:34:14.587 INFO kablam! | Sep 14 07:34:14.587 INFO kablam! 3 | use futures::future::BoxFuture; Sep 14 07:34:14.587 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.587 INFO kablam! | Sep 14 07:34:14.587 INFO kablam! = note: #[warn(deprecated)] on by default Sep 14 07:34:14.587 INFO kablam! Sep 14 07:34:14.587 INFO kablam! 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 Sep 14 07:34:14.587 INFO kablam! --> src/types.rs:5:5 Sep 14 07:34:14.587 INFO kablam! | Sep 14 07:34:14.587 INFO kablam! 5 | use futures::stream::BoxStream; Sep 14 07:34:14.587 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.587 INFO kablam! Sep 14 07:34:14.587 INFO kablam! 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 Sep 14 07:34:14.587 INFO kablam! --> src/types.rs:7:29 Sep 14 07:34:14.587 INFO kablam! | Sep 14 07:34:14.587 INFO kablam! 7 | pub type BoxMqttFuture = BoxFuture; Sep 14 07:34:14.587 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.587 INFO kablam! Sep 14 07:34:14.587 INFO kablam! 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 Sep 14 07:34:14.587 INFO kablam! --> src/types.rs:9:29 Sep 14 07:34:14.587 INFO kablam! | Sep 14 07:34:14.587 INFO kablam! 9 | pub type BoxMqttStream = BoxStream; Sep 14 07:34:14.587 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.587 INFO kablam! Sep 14 07:34:14.587 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Sep 14 07:34:14.587 INFO kablam! --> src/tokio/mod.rs:12:5 Sep 14 07:34:14.587 INFO kablam! | Sep 14 07:34:14.587 INFO kablam! 12 | use tokio_io::codec::Framed; Sep 14 07:34:14.587 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.587 INFO kablam! Sep 14 07:34:14.587 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Sep 14 07:34:14.587 INFO kablam! --> src/tokio/mod.rs:27:40 Sep 14 07:34:14.587 INFO kablam! | Sep 14 07:34:14.587 INFO kablam! 27 | type MqttFramedReader = SplitStream>; Sep 14 07:34:14.587 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.587 INFO kablam! Sep 14 07:34:14.587 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Sep 14 07:34:14.587 INFO kablam! --> src/tokio/mod.rs:28:38 Sep 14 07:34:14.587 INFO kablam! | Sep 14 07:34:14.587 INFO kablam! 28 | type MqttFramedWriter = SplitSink>; Sep 14 07:34:14.587 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.587 INFO kablam! Sep 14 07:34:14.619 INFO kablam! 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 Sep 14 07:34:14.619 INFO kablam! --> src/types.rs:3:5 Sep 14 07:34:14.619 INFO kablam! | Sep 14 07:34:14.619 INFO kablam! 3 | use futures::future::BoxFuture; Sep 14 07:34:14.619 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.619 INFO kablam! | Sep 14 07:34:14.619 INFO kablam! = note: #[warn(deprecated)] on by default Sep 14 07:34:14.619 INFO kablam! Sep 14 07:34:14.619 INFO kablam! 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 Sep 14 07:34:14.619 INFO kablam! --> src/types.rs:5:5 Sep 14 07:34:14.619 INFO kablam! | Sep 14 07:34:14.619 INFO kablam! 5 | use futures::stream::BoxStream; Sep 14 07:34:14.619 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.619 INFO kablam! Sep 14 07:34:14.619 INFO kablam! 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 Sep 14 07:34:14.619 INFO kablam! --> src/types.rs:7:29 Sep 14 07:34:14.619 INFO kablam! | Sep 14 07:34:14.619 INFO kablam! 7 | pub type BoxMqttFuture = BoxFuture; Sep 14 07:34:14.619 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.619 INFO kablam! Sep 14 07:34:14.619 INFO kablam! 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 Sep 14 07:34:14.619 INFO kablam! --> src/types.rs:9:29 Sep 14 07:34:14.619 INFO kablam! | Sep 14 07:34:14.619 INFO kablam! 9 | pub type BoxMqttStream = BoxStream; Sep 14 07:34:14.619 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.619 INFO kablam! Sep 14 07:34:14.619 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Sep 14 07:34:14.619 INFO kablam! --> src/tokio/mod.rs:12:5 Sep 14 07:34:14.619 INFO kablam! | Sep 14 07:34:14.619 INFO kablam! 12 | use tokio_io::codec::Framed; Sep 14 07:34:14.619 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.619 INFO kablam! Sep 14 07:34:14.619 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Sep 14 07:34:14.619 INFO kablam! --> src/tokio/mod.rs:27:40 Sep 14 07:34:14.619 INFO kablam! | Sep 14 07:34:14.619 INFO kablam! 27 | type MqttFramedReader = SplitStream>; Sep 14 07:34:14.619 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.619 INFO kablam! Sep 14 07:34:14.619 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Sep 14 07:34:14.620 INFO kablam! --> src/tokio/mod.rs:28:38 Sep 14 07:34:14.620 INFO kablam! | Sep 14 07:34:14.620 INFO kablam! 28 | type MqttFramedWriter = SplitSink>; Sep 14 07:34:14.620 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:14.620 INFO kablam! Sep 14 07:34:15.192 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Sep 14 07:34:15.192 INFO kablam! --> src/proto/types.rs:271:13 Sep 14 07:34:15.192 INFO kablam! | Sep 14 07:34:15.192 INFO kablam! 271 | out.put_u16::(self.len() as u16); Sep 14 07:34:15.192 INFO kablam! | ^^^^^^^ Sep 14 07:34:15.195 INFO kablam! Sep 14 07:34:15.338 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Sep 14 07:34:15.338 INFO kablam! --> src/proto/headers.rs:135:40 Sep 14 07:34:15.338 INFO kablam! | Sep 14 07:34:15.338 INFO kablam! 135 | Ok(PacketId(raw.into_buf().get_u16::())) Sep 14 07:34:15.338 INFO kablam! | ^^^^^^^ Sep 14 07:34:15.343 INFO kablam! Sep 14 07:34:15.343 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Sep 14 07:34:15.343 INFO kablam! --> src/proto/headers.rs:140:13 Sep 14 07:34:15.343 INFO kablam! | Sep 14 07:34:15.343 INFO kablam! 140 | out.put_u16::(self.0); Sep 14 07:34:15.343 INFO kablam! | ^^^^^^^ Sep 14 07:34:15.343 INFO kablam! Sep 14 07:34:15.343 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Sep 14 07:34:15.343 INFO kablam! --> src/proto/headers.rs:170:41 Sep 14 07:34:15.343 INFO kablam! | Sep 14 07:34:15.344 INFO kablam! 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Sep 14 07:34:15.344 INFO kablam! | ^^^^^^^ Sep 14 07:34:15.344 INFO kablam! Sep 14 07:34:15.344 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Sep 14 07:34:15.344 INFO kablam! --> src/proto/headers.rs:175:13 Sep 14 07:34:15.344 INFO kablam! | Sep 14 07:34:15.344 INFO kablam! 175 | out.put_u16::(self.0); Sep 14 07:34:15.344 INFO kablam! | ^^^^^^^ Sep 14 07:34:15.344 INFO kablam! Sep 14 07:34:15.344 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Sep 14 07:34:15.344 INFO kablam! --> src/proto/types.rs:271:13 Sep 14 07:34:15.344 INFO kablam! | Sep 14 07:34:15.344 INFO kablam! 271 | out.put_u16::(self.len() as u16); Sep 14 07:34:15.344 INFO kablam! | ^^^^^^^ Sep 14 07:34:15.344 INFO kablam! Sep 14 07:34:15.375 INFO kablam! 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 Sep 14 07:34:15.375 INFO kablam! --> src/client.rs:223:55 Sep 14 07:34:15.375 INFO kablam! | Sep 14 07:34:15.375 INFO kablam! 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Sep 14 07:34:15.375 INFO kablam! | ^^^^^ Sep 14 07:34:15.375 INFO kablam! Sep 14 07:34:15.383 INFO kablam! 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 Sep 14 07:34:15.383 INFO kablam! --> src/client.rs:266:63 Sep 14 07:34:15.383 INFO kablam! | Sep 14 07:34:15.383 INFO kablam! 266 | client.request(connect).into_future().map(|_| ()).boxed() Sep 14 07:34:15.383 INFO kablam! | ^^^^^ Sep 14 07:34:15.383 INFO kablam! Sep 14 07:34:15.455 INFO kablam! warning: use of deprecated item '>::send': renamed to `unbounded_send` Sep 14 07:34:15.455 INFO kablam! --> src/tokio/mqtt_loop.rs:54:32 Sep 14 07:34:15.455 INFO kablam! | Sep 14 07:34:15.455 INFO kablam! 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Sep 14 07:34:15.455 INFO kablam! | ^^^^ Sep 14 07:34:15.455 INFO kablam! Sep 14 07:34:15.459 INFO kablam! 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 Sep 14 07:34:15.459 INFO kablam! --> src/tokio/mqtt_loop.rs:60:47 Sep 14 07:34:15.459 INFO kablam! | Sep 14 07:34:15.459 INFO kablam! 60 | Ok((next_state(sender), Ok(rx.boxed()))) Sep 14 07:34:15.459 INFO kablam! | ^^^^^ Sep 14 07:34:15.459 INFO kablam! Sep 14 07:34:15.467 INFO kablam! warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Sep 14 07:34:15.467 INFO kablam! --> src/tokio/mqtt_loop.rs:266:34 Sep 14 07:34:15.467 INFO kablam! | Sep 14 07:34:15.467 INFO kablam! 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Sep 14 07:34:15.467 INFO kablam! | ^^^^^^ Sep 14 07:34:15.467 INFO kablam! Sep 14 07:34:15.483 INFO kablam! 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 Sep 14 07:34:15.483 INFO kablam! --> src/tokio/mqtt_loop.rs:317:14 Sep 14 07:34:15.483 INFO kablam! | Sep 14 07:34:15.483 INFO kablam! 317 | .boxed() Sep 14 07:34:15.483 INFO kablam! | ^^^^^ Sep 14 07:34:15.483 INFO kablam! Sep 14 07:34:15.504 INFO kablam! 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 Sep 14 07:34:15.504 INFO kablam! --> src/tokio/mqtt_loop.rs:519:42 Sep 14 07:34:15.504 INFO kablam! | Sep 14 07:34:15.504 INFO kablam! 519 | .boxed(), Sep 14 07:34:15.504 INFO kablam! | ^^^^^ Sep 14 07:34:15.504 INFO kablam! Sep 14 07:34:15.519 INFO kablam! 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 Sep 14 07:34:15.519 INFO kablam! --> src/tokio/response.rs:83:40 Sep 14 07:34:15.519 INFO kablam! | Sep 14 07:34:15.519 INFO kablam! 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Sep 14 07:34:15.519 INFO kablam! | ^^^^^ Sep 14 07:34:15.519 INFO kablam! Sep 14 07:34:15.574 INFO kablam! 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 Sep 14 07:34:15.574 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Sep 14 07:34:15.574 INFO kablam! | Sep 14 07:34:15.574 INFO kablam! 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Sep 14 07:34:15.574 INFO kablam! | ^^^^^ Sep 14 07:34:15.574 INFO kablam! Sep 14 07:34:15.691 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Sep 14 07:34:15.691 INFO kablam! --> src/proto/headers.rs:135:40 Sep 14 07:34:15.691 INFO kablam! | Sep 14 07:34:15.691 INFO kablam! 135 | Ok(PacketId(raw.into_buf().get_u16::())) Sep 14 07:34:15.691 INFO kablam! | ^^^^^^^ Sep 14 07:34:15.691 INFO kablam! Sep 14 07:34:15.691 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Sep 14 07:34:15.691 INFO kablam! --> src/proto/headers.rs:140:13 Sep 14 07:34:15.691 INFO kablam! | Sep 14 07:34:15.691 INFO kablam! 140 | out.put_u16::(self.0); Sep 14 07:34:15.691 INFO kablam! | ^^^^^^^ Sep 14 07:34:15.691 INFO kablam! Sep 14 07:34:15.691 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Sep 14 07:34:15.691 INFO kablam! --> src/proto/headers.rs:170:41 Sep 14 07:34:15.691 INFO kablam! | Sep 14 07:34:15.691 INFO kablam! 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Sep 14 07:34:15.691 INFO kablam! | ^^^^^^^ Sep 14 07:34:15.691 INFO kablam! Sep 14 07:34:15.691 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Sep 14 07:34:15.691 INFO kablam! --> src/proto/headers.rs:175:13 Sep 14 07:34:15.691 INFO kablam! | Sep 14 07:34:15.691 INFO kablam! 175 | out.put_u16::(self.0); Sep 14 07:34:15.691 INFO kablam! | ^^^^^^^ Sep 14 07:34:15.691 INFO kablam! Sep 14 07:34:15.707 INFO kablam! 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 Sep 14 07:34:15.707 INFO kablam! --> src/client.rs:223:55 Sep 14 07:34:15.707 INFO kablam! | Sep 14 07:34:15.707 INFO kablam! 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Sep 14 07:34:15.707 INFO kablam! | ^^^^^ Sep 14 07:34:15.707 INFO kablam! Sep 14 07:34:15.723 INFO kablam! 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 Sep 14 07:34:15.723 INFO kablam! --> src/client.rs:266:63 Sep 14 07:34:15.723 INFO kablam! | Sep 14 07:34:15.723 INFO kablam! 266 | client.request(connect).into_future().map(|_| ()).boxed() Sep 14 07:34:15.723 INFO kablam! | ^^^^^ Sep 14 07:34:15.723 INFO kablam! Sep 14 07:34:15.782 INFO kablam! warning: use of deprecated item '>::send': renamed to `unbounded_send` Sep 14 07:34:15.782 INFO kablam! --> src/tokio/mqtt_loop.rs:54:32 Sep 14 07:34:15.782 INFO kablam! | Sep 14 07:34:15.782 INFO kablam! 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Sep 14 07:34:15.782 INFO kablam! | ^^^^ Sep 14 07:34:15.787 INFO kablam! Sep 14 07:34:15.790 INFO kablam! 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 Sep 14 07:34:15.791 INFO kablam! --> src/tokio/mqtt_loop.rs:60:47 Sep 14 07:34:15.791 INFO kablam! | Sep 14 07:34:15.791 INFO kablam! 60 | Ok((next_state(sender), Ok(rx.boxed()))) Sep 14 07:34:15.791 INFO kablam! | ^^^^^ Sep 14 07:34:15.791 INFO kablam! Sep 14 07:34:15.799 INFO kablam! warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Sep 14 07:34:15.799 INFO kablam! --> src/tokio/mqtt_loop.rs:266:34 Sep 14 07:34:15.799 INFO kablam! | Sep 14 07:34:15.799 INFO kablam! 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Sep 14 07:34:15.799 INFO kablam! | ^^^^^^ Sep 14 07:34:15.799 INFO kablam! Sep 14 07:34:15.822 INFO kablam! 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 Sep 14 07:34:15.822 INFO kablam! --> src/tokio/mqtt_loop.rs:317:14 Sep 14 07:34:15.822 INFO kablam! | Sep 14 07:34:15.822 INFO kablam! 317 | .boxed() Sep 14 07:34:15.822 INFO kablam! | ^^^^^ Sep 14 07:34:15.822 INFO kablam! Sep 14 07:34:15.835 INFO kablam! 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 Sep 14 07:34:15.836 INFO kablam! --> src/tokio/mqtt_loop.rs:519:42 Sep 14 07:34:15.836 INFO kablam! | Sep 14 07:34:15.836 INFO kablam! 519 | .boxed(), Sep 14 07:34:15.836 INFO kablam! | ^^^^^ Sep 14 07:34:15.843 INFO kablam! Sep 14 07:34:15.857 INFO kablam! 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 Sep 14 07:34:15.858 INFO kablam! --> src/tokio/response.rs:83:40 Sep 14 07:34:15.858 INFO kablam! | Sep 14 07:34:15.858 INFO kablam! 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Sep 14 07:34:15.858 INFO kablam! | ^^^^^ Sep 14 07:34:15.858 INFO kablam! Sep 14 07:34:15.861 INFO kablam! warning: unused import: `Sink` Sep 14 07:34:15.861 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Sep 14 07:34:15.861 INFO kablam! | Sep 14 07:34:15.861 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:15.861 INFO kablam! | ^^^^ Sep 14 07:34:15.862 INFO kablam! Sep 14 07:34:15.862 INFO kablam! warning: unused import: `Sink` Sep 14 07:34:15.862 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Sep 14 07:34:15.862 INFO kablam! | Sep 14 07:34:15.862 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:15.862 INFO kablam! | ^^^^ Sep 14 07:34:15.862 INFO kablam! Sep 14 07:34:15.862 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:15.862 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Sep 14 07:34:15.862 INFO kablam! | Sep 14 07:34:15.862 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:15.862 INFO kablam! | ^^^^^^ Sep 14 07:34:15.862 INFO kablam! Sep 14 07:34:15.862 INFO kablam! warning: unused import: `Sink` Sep 14 07:34:15.862 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:39 Sep 14 07:34:15.862 INFO kablam! | Sep 14 07:34:15.862 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:15.862 INFO kablam! | ^^^^ Sep 14 07:34:15.862 INFO kablam! Sep 14 07:34:15.862 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:15.862 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:53 Sep 14 07:34:15.862 INFO kablam! | Sep 14 07:34:15.862 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:15.862 INFO kablam! | ^^^^^^ Sep 14 07:34:15.862 INFO kablam! Sep 14 07:34:15.862 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:15.862 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:53 Sep 14 07:34:15.862 INFO kablam! | Sep 14 07:34:15.862 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:15.862 INFO kablam! | ^^^^^^ Sep 14 07:34:15.862 INFO kablam! Sep 14 07:34:15.863 INFO kablam! warning: unused import: `Sink` Sep 14 07:34:15.863 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Sep 14 07:34:15.863 INFO kablam! | Sep 14 07:34:15.863 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:15.863 INFO kablam! | ^^^^ Sep 14 07:34:15.863 INFO kablam! Sep 14 07:34:15.863 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:15.863 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Sep 14 07:34:15.863 INFO kablam! | Sep 14 07:34:15.863 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:15.863 INFO kablam! | ^^^^^^ Sep 14 07:34:15.863 INFO kablam! Sep 14 07:34:15.863 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:15.863 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Sep 14 07:34:15.863 INFO kablam! | Sep 14 07:34:15.863 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:15.863 INFO kablam! | ^^^^^^ Sep 14 07:34:15.863 INFO kablam! Sep 14 07:34:15.863 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:15.863 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:53 Sep 14 07:34:15.863 INFO kablam! | Sep 14 07:34:15.863 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:15.863 INFO kablam! | ^^^^^^ Sep 14 07:34:15.863 INFO kablam! Sep 14 07:34:15.930 INFO kablam! 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 Sep 14 07:34:15.930 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Sep 14 07:34:15.930 INFO kablam! | Sep 14 07:34:15.930 INFO kablam! 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Sep 14 07:34:15.930 INFO kablam! | ^^^^^ Sep 14 07:34:15.930 INFO kablam! Sep 14 07:34:16.291 INFO kablam! warning: unused import: `Sink` Sep 14 07:34:16.291 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Sep 14 07:34:16.291 INFO kablam! | Sep 14 07:34:16.291 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:16.291 INFO kablam! | ^^^^ Sep 14 07:34:16.291 INFO kablam! Sep 14 07:34:16.291 INFO kablam! warning: unused import: `Sink` Sep 14 07:34:16.291 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Sep 14 07:34:16.291 INFO kablam! | Sep 14 07:34:16.291 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:16.291 INFO kablam! | ^^^^ Sep 14 07:34:16.291 INFO kablam! Sep 14 07:34:16.291 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:16.291 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Sep 14 07:34:16.291 INFO kablam! | Sep 14 07:34:16.291 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:16.291 INFO kablam! | ^^^^^^ Sep 14 07:34:16.291 INFO kablam! Sep 14 07:34:16.291 INFO kablam! warning: unused import: `Sink` Sep 14 07:34:16.291 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:39 Sep 14 07:34:16.291 INFO kablam! | Sep 14 07:34:16.291 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:16.291 INFO kablam! | ^^^^ Sep 14 07:34:16.291 INFO kablam! Sep 14 07:34:16.291 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:16.291 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:53 Sep 14 07:34:16.291 INFO kablam! | Sep 14 07:34:16.291 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:16.291 INFO kablam! | ^^^^^^ Sep 14 07:34:16.291 INFO kablam! Sep 14 07:34:16.291 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:16.291 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:53 Sep 14 07:34:16.291 INFO kablam! | Sep 14 07:34:16.291 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:16.291 INFO kablam! | ^^^^^^ Sep 14 07:34:16.291 INFO kablam! Sep 14 07:34:16.291 INFO kablam! warning: unused import: `Sink` Sep 14 07:34:16.292 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Sep 14 07:34:16.292 INFO kablam! | Sep 14 07:34:16.292 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:16.292 INFO kablam! | ^^^^ Sep 14 07:34:16.292 INFO kablam! Sep 14 07:34:16.292 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:16.292 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Sep 14 07:34:16.292 INFO kablam! | Sep 14 07:34:16.292 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:16.292 INFO kablam! | ^^^^^^ Sep 14 07:34:16.292 INFO kablam! Sep 14 07:34:16.292 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:16.292 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Sep 14 07:34:16.292 INFO kablam! | Sep 14 07:34:16.292 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:16.292 INFO kablam! | ^^^^^^ Sep 14 07:34:16.292 INFO kablam! Sep 14 07:34:16.292 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:16.292 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:53 Sep 14 07:34:16.292 INFO kablam! | Sep 14 07:34:16.292 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Sep 14 07:34:16.292 INFO kablam! | ^^^^^^ Sep 14 07:34:16.292 INFO kablam! Sep 14 07:34:16.727 INFO kablam! warning: variable does not need to be mutable Sep 14 07:34:16.727 INFO kablam! --> src/tokio/mqtt_loop.rs:320:31 Sep 14 07:34:16.727 INFO kablam! | Sep 14 07:34:16.727 INFO kablam! 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Sep 14 07:34:16.727 INFO kablam! | ----^^^ Sep 14 07:34:16.727 INFO kablam! | | Sep 14 07:34:16.727 INFO kablam! | help: remove this `mut` Sep 14 07:34:16.727 INFO kablam! | Sep 14 07:34:16.727 INFO kablam! = note: #[warn(unused_mut)] on by default Sep 14 07:34:16.727 INFO kablam! Sep 14 07:34:17.138 INFO kablam! warning: unused `std::result::Result` which must be used Sep 14 07:34:17.139 INFO kablam! --> src/tokio/mqtt_loop.rs:571:17 Sep 14 07:34:17.139 INFO kablam! | Sep 14 07:34:17.139 INFO kablam! 571 | self.poll_queues(sourceitem); Sep 14 07:34:17.139 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:17.139 INFO kablam! | Sep 14 07:34:17.139 INFO kablam! = note: #[warn(unused_must_use)] on by default Sep 14 07:34:17.139 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Sep 14 07:34:17.139 INFO kablam! Sep 14 07:34:17.145 INFO kablam! warning: unused `std::result::Result` which must be used Sep 14 07:34:17.145 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:104:25 Sep 14 07:34:17.145 INFO kablam! | Sep 14 07:34:17.145 INFO kablam! 104 | / requester.unbounded_send(LoopRequest::Internal( Sep 14 07:34:17.145 INFO kablam! 105 | | MqttPacket::pub_ack_packet(*id), Sep 14 07:34:17.146 INFO kablam! 106 | | )); Sep 14 07:34:17.146 INFO kablam! | |___________________________^ Sep 14 07:34:17.146 INFO kablam! | Sep 14 07:34:17.146 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Sep 14 07:34:17.146 INFO kablam! Sep 14 07:34:17.146 INFO kablam! warning: unused `std::result::Result` which must be used Sep 14 07:34:17.146 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:128:29 Sep 14 07:34:17.146 INFO kablam! | Sep 14 07:34:17.146 INFO kablam! 128 | / requester.unbounded_send( Sep 14 07:34:17.146 INFO kablam! 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Sep 14 07:34:17.146 INFO kablam! 130 | | ); Sep 14 07:34:17.146 INFO kablam! | |______________________________^ Sep 14 07:34:17.146 INFO kablam! | Sep 14 07:34:17.146 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Sep 14 07:34:17.146 INFO kablam! Sep 14 07:34:17.146 INFO kablam! warning: unused `futures::sink::Send` which must be used Sep 14 07:34:17.146 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Sep 14 07:34:17.146 INFO kablam! | Sep 14 07:34:17.146 INFO kablam! 100 | requester.send(LoopRequest::Internal(rel)); Sep 14 07:34:17.146 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:17.146 INFO kablam! | Sep 14 07:34:17.146 INFO kablam! = note: futures do nothing unless polled Sep 14 07:34:17.146 INFO kablam! Sep 14 07:34:17.403 INFO kablam! warning: variable does not need to be mutable Sep 14 07:34:17.403 INFO kablam! --> src/tokio/mqtt_loop.rs:320:31 Sep 14 07:34:17.403 INFO kablam! | Sep 14 07:34:17.403 INFO kablam! 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Sep 14 07:34:17.403 INFO kablam! | ----^^^ Sep 14 07:34:17.403 INFO kablam! | | Sep 14 07:34:17.403 INFO kablam! | help: remove this `mut` Sep 14 07:34:17.403 INFO kablam! | Sep 14 07:34:17.403 INFO kablam! = note: #[warn(unused_mut)] on by default Sep 14 07:34:17.403 INFO kablam! Sep 14 07:34:18.016 INFO kablam! warning: unused `std::result::Result` which must be used Sep 14 07:34:18.016 INFO kablam! --> src/tokio/mqtt_loop.rs:571:17 Sep 14 07:34:18.016 INFO kablam! | Sep 14 07:34:18.016 INFO kablam! 571 | self.poll_queues(sourceitem); Sep 14 07:34:18.016 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:18.016 INFO kablam! | Sep 14 07:34:18.016 INFO kablam! = note: #[warn(unused_must_use)] on by default Sep 14 07:34:18.016 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Sep 14 07:34:18.016 INFO kablam! Sep 14 07:34:18.031 INFO kablam! warning: unused `std::result::Result` which must be used Sep 14 07:34:18.031 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:104:25 Sep 14 07:34:18.031 INFO kablam! | Sep 14 07:34:18.031 INFO kablam! 104 | / requester.unbounded_send(LoopRequest::Internal( Sep 14 07:34:18.031 INFO kablam! 105 | | MqttPacket::pub_ack_packet(*id), Sep 14 07:34:18.031 INFO kablam! 106 | | )); Sep 14 07:34:18.031 INFO kablam! | |___________________________^ Sep 14 07:34:18.031 INFO kablam! | Sep 14 07:34:18.031 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Sep 14 07:34:18.031 INFO kablam! Sep 14 07:34:18.031 INFO kablam! warning: unused `std::result::Result` which must be used Sep 14 07:34:18.031 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:128:29 Sep 14 07:34:18.031 INFO kablam! | Sep 14 07:34:18.031 INFO kablam! 128 | / requester.unbounded_send( Sep 14 07:34:18.031 INFO kablam! 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Sep 14 07:34:18.031 INFO kablam! 130 | | ); Sep 14 07:34:18.031 INFO kablam! | |______________________________^ Sep 14 07:34:18.031 INFO kablam! | Sep 14 07:34:18.031 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Sep 14 07:34:18.031 INFO kablam! Sep 14 07:34:18.031 INFO kablam! warning: unused `futures::sink::Send` which must be used Sep 14 07:34:18.031 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Sep 14 07:34:18.031 INFO kablam! | Sep 14 07:34:18.031 INFO kablam! 100 | requester.send(LoopRequest::Internal(rel)); Sep 14 07:34:18.031 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:18.031 INFO kablam! | Sep 14 07:34:18.031 INFO kablam! = note: futures do nothing unless polled Sep 14 07:34:18.031 INFO kablam! Sep 14 07:34:18.695 INFO kablam! warning: unused `#[macro_use]` import Sep 14 07:34:18.695 INFO kablam! --> examples/client.rs:1:1 Sep 14 07:34:18.695 INFO kablam! | Sep 14 07:34:18.695 INFO kablam! 1 | #[macro_use] Sep 14 07:34:18.695 INFO kablam! | ^^^^^^^^^^^^ Sep 14 07:34:18.695 INFO kablam! | Sep 14 07:34:18.695 INFO kablam! = note: #[warn(unused_imports)] on by default Sep 14 07:34:18.695 INFO kablam! Sep 14 07:34:18.695 INFO kablam! warning: unused import: `tokio_mqttc::persistence::*` Sep 14 07:34:18.695 INFO kablam! --> examples/client.rs:11:5 Sep 14 07:34:18.695 INFO kablam! | Sep 14 07:34:18.695 INFO kablam! 11 | use tokio_mqttc::persistence::*; Sep 14 07:34:18.695 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:18.695 INFO kablam! Sep 14 07:34:18.695 INFO kablam! warning: unused import: `tokio_mqttc::proto::*` Sep 14 07:34:18.695 INFO kablam! --> examples/client.rs:13:5 Sep 14 07:34:18.695 INFO kablam! | Sep 14 07:34:18.695 INFO kablam! 13 | use tokio_mqttc::proto::*; Sep 14 07:34:18.695 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:18.695 INFO kablam! Sep 14 07:34:18.695 INFO kablam! warning: unused import: `tokio_core::reactor::Handle` Sep 14 07:34:18.695 INFO kablam! --> examples/client.rs:41:5 Sep 14 07:34:18.695 INFO kablam! | Sep 14 07:34:18.695 INFO kablam! 41 | use tokio_core::reactor::Handle; Sep 14 07:34:18.695 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Sep 14 07:34:18.695 INFO kablam! Sep 14 07:34:18.695 INFO kablam! warning: unused imports: `Sink`, `future` Sep 14 07:34:18.695 INFO kablam! --> examples/client.rs:45:15 Sep 14 07:34:18.695 INFO kablam! | Sep 14 07:34:18.695 INFO kablam! 45 | use futures::{future, Future, Stream, Sink}; Sep 14 07:34:18.695 INFO kablam! | ^^^^^^ ^^^^ Sep 14 07:34:18.695 INFO kablam! Sep 14 07:34:18.859 INFO kablam! warning: unused import: `Stream` Sep 14 07:34:18.859 INFO kablam! --> examples/client.rs:45:31 Sep 14 07:34:18.859 INFO kablam! | Sep 14 07:34:18.859 INFO kablam! 45 | use futures::{future, Future, Stream, Sink}; Sep 14 07:34:18.859 INFO kablam! | ^^^^^^ Sep 14 07:34:18.859 INFO kablam! Sep 14 07:34:18.943 INFO kablam! Finished dev [unoptimized + debuginfo] target(s) in 8.26s Sep 14 07:34:18.956 INFO kablam! su: No module specific data is present Sep 14 07:34:19.971 INFO running `"docker" "rm" "-f" "9037106d2030db4f053b5df3a4b033af442f08609dfddfe5c826b27675513b51"` Sep 14 07:34:20.035 INFO blam! 9037106d2030db4f053b5df3a4b033af442f08609dfddfe5c826b27675513b51