Jul 11 19:16:31.684 INFO checking tokio-mqttc-0.0.2 against master#ae5b629efd79de78e6ba7ef493c32857bd7f9cf9 for pr-52234 Jul 11 19:16:31.684 INFO running: cargo +ae5b629efd79de78e6ba7ef493c32857bd7f9cf9-alt check --frozen --all --all-targets Jul 11 19:16:31.684 INFO creating container for: cargo +ae5b629efd79de78e6ba7ef493c32857bd7f9cf9-alt check --frozen --all --all-targets Jul 11 19:16:31.684 INFO running `"docker" "create" "-v" "/home/ec2-user/crater/./work/local/test-source/worker-0/pr-52234/master#ae5b629efd79de78e6ba7ef493c32857bd7f9cf9:/source:ro,Z" "-v" "/home/ec2-user/crater/./work/local/target-dirs/pr-52234/worker-0/master#ae5b629efd79de78e6ba7ef493c32857bd7f9cf9:/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=500" "-e" "CMD=cargo +ae5b629efd79de78e6ba7ef493c32857bd7f9cf9-alt check --frozen --all --all-targets" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "crater"` Jul 11 19:16:31.878 INFO blam! 39cc1353744cd4247e2a561d2f70bc61a0549f2f34b44965716d0d84e8843326 Jul 11 19:16:31.880 INFO running `"docker" "start" "-a" "39cc1353744cd4247e2a561d2f70bc61a0549f2f34b44965716d0d84e8843326"` Jul 11 19:16:33.134 INFO kablam! Checking nom v2.2.1 Jul 11 19:16:33.143 INFO kablam! Checking futures-mutex v0.1.2 Jul 11 19:16:33.154 INFO kablam! Checking touch v0.0.1 Jul 11 19:16:33.157 INFO kablam! Checking bincode v0.9.2 Jul 11 19:16:33.161 INFO kablam! Checking linked-hash-map v0.5.1 Jul 11 19:16:33.164 INFO kablam! Checking tokio-core v0.1.17 Jul 11 19:16:38.167 INFO kablam! Checking tokio-tls v0.1.4 Jul 11 19:16:40.300 INFO kablam! Checking nom-test-helpers v2.0.0 Jul 11 19:16:40.302 INFO kablam! Checking tokio-mqttc v0.0.2 (file:///source) Jul 11 19:16:42.736 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:42.736 INFO kablam! --> src/errors.rs:4:1 Jul 11 19:16:42.736 INFO kablam! | Jul 11 19:16:42.736 INFO kablam! 4 | / error_chain! { Jul 11 19:16:42.736 INFO kablam! 5 | | links { Jul 11 19:16:42.736 INFO kablam! 6 | | Protocol(self::proto::Error, self::proto::ErrorKind); Jul 11 19:16:42.736 INFO kablam! 7 | | } Jul 11 19:16:42.736 INFO kablam! ... | Jul 11 19:16:42.736 INFO kablam! 66 | | } Jul 11 19:16:42.736 INFO kablam! 67 | | } Jul 11 19:16:42.736 INFO kablam! | |_^ Jul 11 19:16:42.737 INFO kablam! | Jul 11 19:16:42.737 INFO kablam! = note: #[warn(renamed_and_removed_lints)] on by default Jul 11 19:16:42.737 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:42.737 INFO kablam! Jul 11 19:16:42.737 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:42.737 INFO kablam! --> src/errors.rs:4:1 Jul 11 19:16:42.738 INFO kablam! | Jul 11 19:16:42.738 INFO kablam! 4 | / error_chain! { Jul 11 19:16:42.738 INFO kablam! 5 | | links { Jul 11 19:16:42.738 INFO kablam! 6 | | Protocol(self::proto::Error, self::proto::ErrorKind); Jul 11 19:16:42.738 INFO kablam! 7 | | } Jul 11 19:16:42.738 INFO kablam! ... | Jul 11 19:16:42.738 INFO kablam! 66 | | } Jul 11 19:16:42.738 INFO kablam! 67 | | } Jul 11 19:16:42.738 INFO kablam! | |_^ Jul 11 19:16:42.738 INFO kablam! | Jul 11 19:16:42.738 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:42.738 INFO kablam! Jul 11 19:16:42.739 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:42.739 INFO kablam! --> src/errors.rs:4:1 Jul 11 19:16:42.739 INFO kablam! | Jul 11 19:16:42.739 INFO kablam! 4 | / error_chain! { Jul 11 19:16:42.739 INFO kablam! 5 | | links { Jul 11 19:16:42.739 INFO kablam! 6 | | Protocol(self::proto::Error, self::proto::ErrorKind); Jul 11 19:16:42.739 INFO kablam! 7 | | } Jul 11 19:16:42.739 INFO kablam! ... | Jul 11 19:16:42.739 INFO kablam! 66 | | } Jul 11 19:16:42.739 INFO kablam! 67 | | } Jul 11 19:16:42.739 INFO kablam! | |_^ Jul 11 19:16:42.740 INFO kablam! | Jul 11 19:16:42.740 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:42.740 INFO kablam! Jul 11 19:16:42.741 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:42.741 INFO kablam! --> src/errors.rs:4:1 Jul 11 19:16:42.742 INFO kablam! | Jul 11 19:16:42.742 INFO kablam! 4 | / error_chain! { Jul 11 19:16:42.742 INFO kablam! 5 | | links { Jul 11 19:16:42.742 INFO kablam! 6 | | Protocol(self::proto::Error, self::proto::ErrorKind); Jul 11 19:16:42.742 INFO kablam! 7 | | } Jul 11 19:16:42.742 INFO kablam! ... | Jul 11 19:16:42.742 INFO kablam! 66 | | } Jul 11 19:16:42.742 INFO kablam! 67 | | } Jul 11 19:16:42.742 INFO kablam! | |_^ Jul 11 19:16:42.743 INFO kablam! | Jul 11 19:16:42.743 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:42.743 INFO kablam! Jul 11 19:16:42.744 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:42.744 INFO kablam! --> src/errors.rs:77:5 Jul 11 19:16:42.744 INFO kablam! | Jul 11 19:16:42.744 INFO kablam! 77 | / error_chain!{ Jul 11 19:16:42.744 INFO kablam! 78 | | errors { Jul 11 19:16:42.744 INFO kablam! 79 | | ResponseTimeout(p: PacketType) { Jul 11 19:16:42.744 INFO kablam! 80 | | description("Timeout waiting for server response") Jul 11 19:16:42.744 INFO kablam! ... | Jul 11 19:16:42.744 INFO kablam! 108 | | } Jul 11 19:16:42.744 INFO kablam! 109 | | } Jul 11 19:16:42.744 INFO kablam! | |_____^ Jul 11 19:16:42.744 INFO kablam! | Jul 11 19:16:42.745 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:42.745 INFO kablam! Jul 11 19:16:42.745 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:42.745 INFO kablam! --> src/errors.rs:77:5 Jul 11 19:16:42.745 INFO kablam! | Jul 11 19:16:42.745 INFO kablam! 77 | / error_chain!{ Jul 11 19:16:42.745 INFO kablam! 78 | | errors { Jul 11 19:16:42.745 INFO kablam! 79 | | ResponseTimeout(p: PacketType) { Jul 11 19:16:42.745 INFO kablam! 80 | | description("Timeout waiting for server response") Jul 11 19:16:42.745 INFO kablam! ... | Jul 11 19:16:42.745 INFO kablam! 108 | | } Jul 11 19:16:42.745 INFO kablam! 109 | | } Jul 11 19:16:42.745 INFO kablam! | |_____^ Jul 11 19:16:42.745 INFO kablam! | Jul 11 19:16:42.745 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:42.746 INFO kablam! Jul 11 19:16:42.746 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:42.746 INFO kablam! --> src/errors.rs:77:5 Jul 11 19:16:42.746 INFO kablam! | Jul 11 19:16:42.746 INFO kablam! 77 | / error_chain!{ Jul 11 19:16:42.746 INFO kablam! 78 | | errors { Jul 11 19:16:42.746 INFO kablam! 79 | | ResponseTimeout(p: PacketType) { Jul 11 19:16:42.746 INFO kablam! 80 | | description("Timeout waiting for server response") Jul 11 19:16:42.747 INFO kablam! ... | Jul 11 19:16:42.747 INFO kablam! 108 | | } Jul 11 19:16:42.747 INFO kablam! 109 | | } Jul 11 19:16:42.747 INFO kablam! | |_____^ Jul 11 19:16:42.747 INFO kablam! | Jul 11 19:16:42.747 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:42.747 INFO kablam! Jul 11 19:16:42.748 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:42.748 INFO kablam! --> src/errors.rs:77:5 Jul 11 19:16:42.748 INFO kablam! | Jul 11 19:16:42.748 INFO kablam! 77 | / error_chain!{ Jul 11 19:16:42.748 INFO kablam! 78 | | errors { Jul 11 19:16:42.748 INFO kablam! 79 | | ResponseTimeout(p: PacketType) { Jul 11 19:16:42.748 INFO kablam! 80 | | description("Timeout waiting for server response") Jul 11 19:16:42.748 INFO kablam! ... | Jul 11 19:16:42.748 INFO kablam! 108 | | } Jul 11 19:16:42.748 INFO kablam! 109 | | } Jul 11 19:16:42.748 INFO kablam! | |_____^ Jul 11 19:16:42.749 INFO kablam! | Jul 11 19:16:42.750 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:42.750 INFO kablam! Jul 11 19:16:42.751 INFO kablam! warning: unused import: `Error` Jul 11 19:16:42.751 INFO kablam! --> src/proto/types.rs:4:14 Jul 11 19:16:42.751 INFO kablam! | Jul 11 19:16:42.751 INFO kablam! 4 | use errors::{Error, ErrorKind}; Jul 11 19:16:42.751 INFO kablam! | ^^^^^ Jul 11 19:16:42.751 INFO kablam! | Jul 11 19:16:42.752 INFO kablam! = note: #[warn(unused_imports)] on by default Jul 11 19:16:42.752 INFO kablam! Jul 11 19:16:42.752 INFO kablam! warning: unused import: `linked_hash_map::LinkedHashMap` Jul 11 19:16:42.753 INFO kablam! --> src/proto/types.rs:5:5 Jul 11 19:16:42.753 INFO kablam! | Jul 11 19:16:42.753 INFO kablam! 5 | use linked_hash_map::LinkedHashMap; Jul 11 19:16:42.753 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.753 INFO kablam! Jul 11 19:16:42.767 INFO kablam! warning: unused imports: `IResult`, `be_u16` Jul 11 19:16:42.767 INFO kablam! --> src/proto/headers.rs:3:11 Jul 11 19:16:42.767 INFO kablam! | Jul 11 19:16:42.767 INFO kablam! 3 | use nom::{IResult, be_u16}; Jul 11 19:16:42.767 INFO kablam! | ^^^^^^^ ^^^^^^ Jul 11 19:16:42.767 INFO kablam! Jul 11 19:16:42.768 INFO kablam! warning: unused import: `std::io` Jul 11 19:16:42.768 INFO kablam! --> src/proto/mod.rs:8:5 Jul 11 19:16:42.768 INFO kablam! | Jul 11 19:16:42.768 INFO kablam! 8 | use std::io; Jul 11 19:16:42.768 INFO kablam! | ^^^^^^^ Jul 11 19:16:42.768 INFO kablam! Jul 11 19:16:42.768 INFO kablam! warning: unused import: `Entry` Jul 11 19:16:42.768 INFO kablam! --> src/proto/mod.rs:12:23 Jul 11 19:16:42.768 INFO kablam! | Jul 11 19:16:42.768 INFO kablam! 12 | use linked_hash_map::{Entry,LinkedHashMap}; Jul 11 19:16:42.768 INFO kablam! | ^^^^^ Jul 11 19:16:42.768 INFO kablam! Jul 11 19:16:42.768 INFO kablam! warning: unused import: `Writer` Jul 11 19:16:42.768 INFO kablam! --> src/proto/mod.rs:13:38 Jul 11 19:16:42.768 INFO kablam! | Jul 11 19:16:42.768 INFO kablam! 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Jul 11 19:16:42.769 INFO kablam! | ^^^^^^ Jul 11 19:16:42.769 INFO kablam! Jul 11 19:16:42.769 INFO kablam! warning: unused import: `self::headers::*` Jul 11 19:16:42.769 INFO kablam! --> src/proto/mod.rs:15:5 Jul 11 19:16:42.769 INFO kablam! | Jul 11 19:16:42.769 INFO kablam! 15 | use self::headers::*; Jul 11 19:16:42.769 INFO kablam! | ^^^^^^^^^^^^^^^^ Jul 11 19:16:42.769 INFO kablam! Jul 11 19:16:42.772 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:42.772 INFO kablam! --> src/tokio/mqtt_loop.rs:13:5 Jul 11 19:16:42.772 INFO kablam! | Jul 11 19:16:42.772 INFO kablam! 13 | use take::Take; Jul 11 19:16:42.772 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.772 INFO kablam! Jul 11 19:16:42.772 INFO kablam! warning: unused import: `MqttFramedWriter` Jul 11 19:16:42.773 INFO kablam! --> src/tokio/mqtt_loop.rs:21:13 Jul 11 19:16:42.773 INFO kablam! | Jul 11 19:16:42.773 INFO kablam! 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Jul 11 19:16:42.773 INFO kablam! | ^^^^^^^^^^^^^^^^ Jul 11 19:16:42.773 INFO kablam! Jul 11 19:16:42.773 INFO kablam! warning: unused import: `super::response::ResponseProcessor` Jul 11 19:16:42.773 INFO kablam! --> src/tokio/mqtt_loop.rs:23:5 Jul 11 19:16:42.773 INFO kablam! | Jul 11 19:16:42.773 INFO kablam! 23 | use super::response::ResponseProcessor; Jul 11 19:16:42.773 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.773 INFO kablam! Jul 11 19:16:42.773 INFO kablam! warning: unused import: `super::request::RequestProcessor` Jul 11 19:16:42.773 INFO kablam! --> src/tokio/mqtt_loop.rs:24:5 Jul 11 19:16:42.773 INFO kablam! | Jul 11 19:16:42.773 INFO kablam! 24 | use super::request::RequestProcessor; Jul 11 19:16:42.773 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.773 INFO kablam! Jul 11 19:16:42.776 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:42.776 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:1:16 Jul 11 19:16:42.776 INFO kablam! | Jul 11 19:16:42.776 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:42.776 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:42.776 INFO kablam! Jul 11 19:16:42.776 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Jul 11 19:16:42.776 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:2:28 Jul 11 19:16:42.776 INFO kablam! | Jul 11 19:16:42.776 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Jul 11 19:16:42.776 INFO kablam! | ^^^^^^^^^ ^^^^ Jul 11 19:16:42.776 INFO kablam! Jul 11 19:16:42.776 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:42.776 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:4:5 Jul 11 19:16:42.777 INFO kablam! | Jul 11 19:16:42.777 INFO kablam! 4 | use take::Take; Jul 11 19:16:42.777 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.777 INFO kablam! Jul 11 19:16:42.777 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:42.777 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:6:5 Jul 11 19:16:42.777 INFO kablam! | Jul 11 19:16:42.777 INFO kablam! 6 | use bincode; Jul 11 19:16:42.777 INFO kablam! | ^^^^^^^ Jul 11 19:16:42.777 INFO kablam! Jul 11 19:16:42.778 INFO kablam! warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Jul 11 19:16:42.778 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:9:25 Jul 11 19:16:42.778 INFO kablam! | Jul 11 19:16:42.778 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Jul 11 19:16:42.778 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Jul 11 19:16:42.778 INFO kablam! Jul 11 19:16:42.778 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt` Jul 11 19:16:42.778 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:10:29 Jul 11 19:16:42.778 INFO kablam! | Jul 11 19:16:42.778 INFO kablam! 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:42.778 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.778 INFO kablam! Jul 11 19:16:42.778 INFO kablam! warning: unused import: `PublishState` Jul 11 19:16:42.778 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:12:25 Jul 11 19:16:42.778 INFO kablam! | Jul 11 19:16:42.778 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Jul 11 19:16:42.778 INFO kablam! | ^^^^^^^^^^^^ Jul 11 19:16:42.778 INFO kablam! Jul 11 19:16:42.778 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:42.778 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:1:16 Jul 11 19:16:42.778 INFO kablam! | Jul 11 19:16:42.779 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:42.779 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:42.779 INFO kablam! Jul 11 19:16:42.779 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Jul 11 19:16:42.779 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:2:28 Jul 11 19:16:42.779 INFO kablam! | Jul 11 19:16:42.779 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Jul 11 19:16:42.779 INFO kablam! | ^^^^^^^^^ ^^^^ Jul 11 19:16:42.779 INFO kablam! Jul 11 19:16:42.779 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:42.779 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:4:5 Jul 11 19:16:42.779 INFO kablam! | Jul 11 19:16:42.779 INFO kablam! 4 | use take::Take; Jul 11 19:16:42.779 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.779 INFO kablam! Jul 11 19:16:42.779 INFO kablam! warning: unused import: `PacketType` Jul 11 19:16:42.779 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:9:25 Jul 11 19:16:42.779 INFO kablam! | Jul 11 19:16:42.779 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Jul 11 19:16:42.779 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.779 INFO kablam! Jul 11 19:16:42.779 INFO kablam! warning: unused import: `OneTimeKey` Jul 11 19:16:42.779 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:12:13 Jul 11 19:16:42.779 INFO kablam! | Jul 11 19:16:42.780 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Jul 11 19:16:42.780 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.780 INFO kablam! Jul 11 19:16:42.780 INFO kablam! warning: unused import: `BoxFuture` Jul 11 19:16:42.780 INFO kablam! --> src/tokio/outbound_handlers/mod.rs:8:27 Jul 11 19:16:42.780 INFO kablam! | Jul 11 19:16:42.780 INFO kablam! 8 | use tokio::{RequestTuple, BoxFuture}; Jul 11 19:16:42.780 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:42.780 INFO kablam! Jul 11 19:16:42.780 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:42.780 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Jul 11 19:16:42.780 INFO kablam! | Jul 11 19:16:42.780 INFO kablam! 3 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:42.780 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:42.780 INFO kablam! Jul 11 19:16:42.780 INFO kablam! warning: unused import: `AsyncSink` Jul 11 19:16:42.780 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Jul 11 19:16:42.780 INFO kablam! | Jul 11 19:16:42.780 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:42.780 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:42.780 INFO kablam! Jul 11 19:16:42.780 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Jul 11 19:16:42.780 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Jul 11 19:16:42.781 INFO kablam! | Jul 11 19:16:42.781 INFO kablam! 6 | use futures::unsync::mpsc::UnboundedSender; Jul 11 19:16:42.781 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.781 INFO kablam! Jul 11 19:16:42.781 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:42.781 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Jul 11 19:16:42.781 INFO kablam! | Jul 11 19:16:42.781 INFO kablam! 7 | use take::Take; Jul 11 19:16:42.781 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.781 INFO kablam! Jul 11 19:16:42.781 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:42.781 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Jul 11 19:16:42.781 INFO kablam! | Jul 11 19:16:42.781 INFO kablam! 9 | use bincode; Jul 11 19:16:42.781 INFO kablam! | ^^^^^^^ Jul 11 19:16:42.781 INFO kablam! Jul 11 19:16:42.781 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Jul 11 19:16:42.781 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Jul 11 19:16:42.781 INFO kablam! | Jul 11 19:16:42.781 INFO kablam! 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:42.781 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:42.781 INFO kablam! 12 | PacketId, TopicName}; Jul 11 19:16:42.781 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:42.782 INFO kablam! Jul 11 19:16:42.782 INFO kablam! warning: unused imports: `ResultExt`, `Result` Jul 11 19:16:42.782 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Jul 11 19:16:42.782 INFO kablam! | Jul 11 19:16:42.782 INFO kablam! 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:42.782 INFO kablam! | ^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.782 INFO kablam! Jul 11 19:16:42.782 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Jul 11 19:16:42.782 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Jul 11 19:16:42.782 INFO kablam! | Jul 11 19:16:42.782 INFO kablam! 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Jul 11 19:16:42.782 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.782 INFO kablam! Jul 11 19:16:42.782 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:42.782 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Jul 11 19:16:42.782 INFO kablam! | Jul 11 19:16:42.782 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:42.782 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:42.782 INFO kablam! Jul 11 19:16:42.782 INFO kablam! warning: unused import: `AsyncSink` Jul 11 19:16:42.782 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Jul 11 19:16:42.782 INFO kablam! | Jul 11 19:16:42.782 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:42.783 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:42.783 INFO kablam! Jul 11 19:16:42.783 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:42.783 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Jul 11 19:16:42.783 INFO kablam! | Jul 11 19:16:42.783 INFO kablam! 6 | use futures::sync::mpsc::unbounded; Jul 11 19:16:42.783 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.783 INFO kablam! Jul 11 19:16:42.783 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Jul 11 19:16:42.783 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Jul 11 19:16:42.783 INFO kablam! | Jul 11 19:16:42.783 INFO kablam! 7 | use futures::unsync::mpsc::UnboundedSender; Jul 11 19:16:42.783 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.783 INFO kablam! Jul 11 19:16:42.783 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:42.783 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Jul 11 19:16:42.783 INFO kablam! | Jul 11 19:16:42.783 INFO kablam! 8 | use take::Take; Jul 11 19:16:42.783 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.783 INFO kablam! Jul 11 19:16:42.783 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:42.783 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Jul 11 19:16:42.783 INFO kablam! | Jul 11 19:16:42.784 INFO kablam! 10 | use bincode; Jul 11 19:16:42.784 INFO kablam! | ^^^^^^^ Jul 11 19:16:42.784 INFO kablam! Jul 11 19:16:42.784 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Jul 11 19:16:42.784 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Jul 11 19:16:42.784 INFO kablam! | Jul 11 19:16:42.788 INFO kablam! 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:42.788 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:42.788 INFO kablam! 13 | PacketId, TopicName}; Jul 11 19:16:42.788 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:42.788 INFO kablam! Jul 11 19:16:42.789 INFO kablam! warning: unused imports: `ResultExt`, `Result` Jul 11 19:16:42.789 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Jul 11 19:16:42.789 INFO kablam! | Jul 11 19:16:42.789 INFO kablam! 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:42.789 INFO kablam! | ^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.789 INFO kablam! Jul 11 19:16:42.789 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:42.789 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Jul 11 19:16:42.789 INFO kablam! | Jul 11 19:16:42.789 INFO kablam! 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Jul 11 19:16:42.789 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.790 INFO kablam! Jul 11 19:16:42.790 INFO kablam! warning: unused import: `std::ops::Deref` Jul 11 19:16:42.790 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:2:5 Jul 11 19:16:42.790 INFO kablam! | Jul 11 19:16:42.790 INFO kablam! 2 | use std::ops::Deref; Jul 11 19:16:42.790 INFO kablam! | ^^^^^^^^^^^^^^^ Jul 11 19:16:42.790 INFO kablam! Jul 11 19:16:42.790 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:42.790 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:4:16 Jul 11 19:16:42.790 INFO kablam! | Jul 11 19:16:42.790 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:42.790 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:42.790 INFO kablam! Jul 11 19:16:42.790 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Jul 11 19:16:42.790 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:15 Jul 11 19:16:42.790 INFO kablam! | Jul 11 19:16:42.790 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:42.790 INFO kablam! | ^^^^ ^^^^^^^^^ Jul 11 19:16:42.791 INFO kablam! Jul 11 19:16:42.791 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:42.791 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:7:5 Jul 11 19:16:42.791 INFO kablam! | Jul 11 19:16:42.791 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Jul 11 19:16:42.791 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.791 INFO kablam! Jul 11 19:16:42.791 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Jul 11 19:16:42.791 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:8:5 Jul 11 19:16:42.791 INFO kablam! | Jul 11 19:16:42.791 INFO kablam! 8 | use futures::unsync::mpsc::UnboundedSender; Jul 11 19:16:42.791 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.791 INFO kablam! Jul 11 19:16:42.791 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:42.791 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:9:5 Jul 11 19:16:42.791 INFO kablam! | Jul 11 19:16:42.791 INFO kablam! 9 | use take::Take; Jul 11 19:16:42.791 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.791 INFO kablam! Jul 11 19:16:42.791 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:42.792 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:11:5 Jul 11 19:16:42.792 INFO kablam! | Jul 11 19:16:42.792 INFO kablam! 11 | use bincode; Jul 11 19:16:42.792 INFO kablam! | ^^^^^^^ Jul 11 19:16:42.792 INFO kablam! Jul 11 19:16:42.792 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Jul 11 19:16:42.792 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:13:13 Jul 11 19:16:42.792 INFO kablam! | Jul 11 19:16:42.792 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:42.792 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:42.792 INFO kablam! 14 | PacketId, TopicName}; Jul 11 19:16:42.792 INFO kablam! | ^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.792 INFO kablam! Jul 11 19:16:42.792 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Jul 11 19:16:42.792 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:16:21 Jul 11 19:16:42.792 INFO kablam! | Jul 11 19:16:42.792 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:42.792 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.792 INFO kablam! Jul 11 19:16:42.792 INFO kablam! warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Jul 11 19:16:42.793 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:17:5 Jul 11 19:16:42.793 INFO kablam! | Jul 11 19:16:42.793 INFO kablam! 17 | use errors::proto::ErrorKind as ProtoErrorKind; Jul 11 19:16:42.793 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.793 INFO kablam! Jul 11 19:16:42.793 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:42.793 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:19:25 Jul 11 19:16:42.793 INFO kablam! | Jul 11 19:16:42.793 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Jul 11 19:16:42.793 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.793 INFO kablam! Jul 11 19:16:42.793 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Jul 11 19:16:42.793 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:1:5 Jul 11 19:16:42.793 INFO kablam! | Jul 11 19:16:42.793 INFO kablam! 1 | use std::collections::hash_map::Entry; Jul 11 19:16:42.793 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.793 INFO kablam! Jul 11 19:16:42.793 INFO kablam! warning: unused import: `std::ops::Deref` Jul 11 19:16:42.793 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:2:5 Jul 11 19:16:42.794 INFO kablam! | Jul 11 19:16:42.794 INFO kablam! 2 | use std::ops::Deref; Jul 11 19:16:42.794 INFO kablam! | ^^^^^^^^^^^^^^^ Jul 11 19:16:42.794 INFO kablam! Jul 11 19:16:42.794 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:42.794 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:5:16 Jul 11 19:16:42.794 INFO kablam! | Jul 11 19:16:42.794 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:42.794 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:42.794 INFO kablam! Jul 11 19:16:42.794 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Jul 11 19:16:42.794 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:28 Jul 11 19:16:42.794 INFO kablam! | Jul 11 19:16:42.794 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:42.794 INFO kablam! | ^^^^^^^^^ ^^^^ Jul 11 19:16:42.794 INFO kablam! Jul 11 19:16:42.794 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:42.794 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:7:5 Jul 11 19:16:42.794 INFO kablam! | Jul 11 19:16:42.794 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Jul 11 19:16:42.795 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.795 INFO kablam! Jul 11 19:16:42.795 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:42.795 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:9:5 Jul 11 19:16:42.795 INFO kablam! | Jul 11 19:16:42.795 INFO kablam! 9 | use take::Take; Jul 11 19:16:42.795 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.795 INFO kablam! Jul 11 19:16:42.795 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:42.795 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:11:5 Jul 11 19:16:42.795 INFO kablam! | Jul 11 19:16:42.795 INFO kablam! 11 | use bincode; Jul 11 19:16:42.795 INFO kablam! | ^^^^^^^ Jul 11 19:16:42.795 INFO kablam! Jul 11 19:16:42.795 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Jul 11 19:16:42.795 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:13:25 Jul 11 19:16:42.795 INFO kablam! | Jul 11 19:16:42.795 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:42.796 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:42.796 INFO kablam! Jul 11 19:16:42.796 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Jul 11 19:16:42.796 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:16:21 Jul 11 19:16:42.796 INFO kablam! | Jul 11 19:16:42.796 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:42.796 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.796 INFO kablam! Jul 11 19:16:42.796 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:42.796 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:19:13 Jul 11 19:16:42.796 INFO kablam! | Jul 11 19:16:42.796 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Jul 11 19:16:42.796 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.796 INFO kablam! Jul 11 19:16:42.796 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Jul 11 19:16:42.796 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Jul 11 19:16:42.796 INFO kablam! | Jul 11 19:16:42.796 INFO kablam! 1 | use std::collections::hash_map::Entry; Jul 11 19:16:42.797 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.797 INFO kablam! Jul 11 19:16:42.797 INFO kablam! warning: unused import: `std::ops::Deref` Jul 11 19:16:42.797 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Jul 11 19:16:42.797 INFO kablam! | Jul 11 19:16:42.797 INFO kablam! 2 | use std::ops::Deref; Jul 11 19:16:42.797 INFO kablam! | ^^^^^^^^^^^^^^^ Jul 11 19:16:42.797 INFO kablam! Jul 11 19:16:42.797 INFO kablam! warning: unused import: `bytes::Bytes` Jul 11 19:16:42.797 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Jul 11 19:16:42.797 INFO kablam! | Jul 11 19:16:42.797 INFO kablam! 4 | use bytes::Bytes; Jul 11 19:16:42.797 INFO kablam! | ^^^^^^^^^^^^ Jul 11 19:16:42.797 INFO kablam! Jul 11 19:16:42.797 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:42.797 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Jul 11 19:16:42.797 INFO kablam! | Jul 11 19:16:42.797 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:42.798 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:42.798 INFO kablam! Jul 11 19:16:42.798 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Jul 11 19:16:42.798 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Jul 11 19:16:42.798 INFO kablam! | Jul 11 19:16:42.798 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:42.798 INFO kablam! | ^^^^ ^^^^^^^^^ Jul 11 19:16:42.806 INFO kablam! Jul 11 19:16:42.806 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:42.806 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Jul 11 19:16:42.807 INFO kablam! | Jul 11 19:16:42.807 INFO kablam! 8 | use futures::sync::mpsc::unbounded; Jul 11 19:16:42.807 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.807 INFO kablam! Jul 11 19:16:42.807 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Jul 11 19:16:42.807 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Jul 11 19:16:42.807 INFO kablam! | Jul 11 19:16:42.807 INFO kablam! 9 | use futures::unsync::mpsc::UnboundedSender; Jul 11 19:16:42.808 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.808 INFO kablam! Jul 11 19:16:42.808 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:42.808 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Jul 11 19:16:42.808 INFO kablam! | Jul 11 19:16:42.808 INFO kablam! 10 | use take::Take; Jul 11 19:16:42.808 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.808 INFO kablam! Jul 11 19:16:42.809 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:42.809 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Jul 11 19:16:42.809 INFO kablam! | Jul 11 19:16:42.809 INFO kablam! 12 | use bincode; Jul 11 19:16:42.809 INFO kablam! | ^^^^^^^ Jul 11 19:16:42.809 INFO kablam! Jul 11 19:16:42.809 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Jul 11 19:16:42.809 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Jul 11 19:16:42.810 INFO kablam! | Jul 11 19:16:42.810 INFO kablam! 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:42.810 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:42.810 INFO kablam! 15 | PacketId, TopicName}; Jul 11 19:16:42.810 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:42.810 INFO kablam! Jul 11 19:16:42.810 INFO kablam! warning: unused import: `Result` Jul 11 19:16:42.810 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Jul 11 19:16:42.811 INFO kablam! | Jul 11 19:16:42.811 INFO kablam! 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:42.811 INFO kablam! | ^^^^^^ Jul 11 19:16:42.811 INFO kablam! Jul 11 19:16:42.811 INFO kablam! warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:42.811 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Jul 11 19:16:42.811 INFO kablam! | Jul 11 19:16:42.811 INFO kablam! 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Jul 11 19:16:42.812 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.812 INFO kablam! Jul 11 19:16:42.812 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Jul 11 19:16:42.812 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Jul 11 19:16:42.812 INFO kablam! | Jul 11 19:16:42.812 INFO kablam! 1 | use std::collections::hash_map::Entry; Jul 11 19:16:42.812 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.813 INFO kablam! Jul 11 19:16:42.813 INFO kablam! warning: unused import: `std::ops::Deref` Jul 11 19:16:42.813 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Jul 11 19:16:42.813 INFO kablam! | Jul 11 19:16:42.813 INFO kablam! 2 | use std::ops::Deref; Jul 11 19:16:42.813 INFO kablam! | ^^^^^^^^^^^^^^^ Jul 11 19:16:42.813 INFO kablam! Jul 11 19:16:42.813 INFO kablam! warning: unused import: `bytes::Bytes` Jul 11 19:16:42.814 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Jul 11 19:16:42.814 INFO kablam! | Jul 11 19:16:42.814 INFO kablam! 4 | use bytes::Bytes; Jul 11 19:16:42.814 INFO kablam! | ^^^^^^^^^^^^ Jul 11 19:16:42.814 INFO kablam! Jul 11 19:16:42.814 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:42.814 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Jul 11 19:16:42.814 INFO kablam! | Jul 11 19:16:42.815 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:42.815 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:42.815 INFO kablam! Jul 11 19:16:42.815 INFO kablam! warning: unused import: `AsyncSink` Jul 11 19:16:42.815 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Jul 11 19:16:42.815 INFO kablam! | Jul 11 19:16:42.815 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:42.815 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:42.816 INFO kablam! Jul 11 19:16:42.816 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:42.816 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Jul 11 19:16:42.816 INFO kablam! | Jul 11 19:16:42.816 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Jul 11 19:16:42.816 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.816 INFO kablam! Jul 11 19:16:42.816 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:42.817 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Jul 11 19:16:42.817 INFO kablam! | Jul 11 19:16:42.817 INFO kablam! 9 | use take::Take; Jul 11 19:16:42.817 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.817 INFO kablam! Jul 11 19:16:42.817 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Jul 11 19:16:42.817 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Jul 11 19:16:42.817 INFO kablam! | Jul 11 19:16:42.818 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:42.818 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:42.818 INFO kablam! 14 | PacketId, TopicName}; Jul 11 19:16:42.818 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:42.818 INFO kablam! Jul 11 19:16:42.818 INFO kablam! warning: unused import: `Result` Jul 11 19:16:42.818 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Jul 11 19:16:42.818 INFO kablam! | Jul 11 19:16:42.819 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:42.819 INFO kablam! | ^^^^^^ Jul 11 19:16:42.819 INFO kablam! Jul 11 19:16:42.819 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:42.819 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Jul 11 19:16:42.819 INFO kablam! | Jul 11 19:16:42.819 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Jul 11 19:16:42.820 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.820 INFO kablam! Jul 11 19:16:42.820 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Jul 11 19:16:42.820 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:1:5 Jul 11 19:16:42.820 INFO kablam! | Jul 11 19:16:42.820 INFO kablam! 1 | use std::collections::hash_map::Entry; Jul 11 19:16:42.820 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.820 INFO kablam! Jul 11 19:16:42.821 INFO kablam! warning: unused import: `std::ops::Deref` Jul 11 19:16:42.821 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:2:5 Jul 11 19:16:42.821 INFO kablam! | Jul 11 19:16:42.821 INFO kablam! 2 | use std::ops::Deref; Jul 11 19:16:42.821 INFO kablam! | ^^^^^^^^^^^^^^^ Jul 11 19:16:42.821 INFO kablam! Jul 11 19:16:42.821 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:42.821 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:5:16 Jul 11 19:16:42.822 INFO kablam! | Jul 11 19:16:42.822 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:42.822 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:42.822 INFO kablam! Jul 11 19:16:42.822 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Jul 11 19:16:42.822 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:28 Jul 11 19:16:42.822 INFO kablam! | Jul 11 19:16:42.822 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:42.823 INFO kablam! | ^^^^^^^^^ ^^^^ Jul 11 19:16:42.823 INFO kablam! Jul 11 19:16:42.823 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:42.823 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:7:5 Jul 11 19:16:42.823 INFO kablam! | Jul 11 19:16:42.823 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Jul 11 19:16:42.823 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.824 INFO kablam! Jul 11 19:16:42.824 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:42.824 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:9:5 Jul 11 19:16:42.824 INFO kablam! | Jul 11 19:16:42.824 INFO kablam! 9 | use take::Take; Jul 11 19:16:42.824 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:42.824 INFO kablam! Jul 11 19:16:42.825 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:42.825 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:11:5 Jul 11 19:16:42.825 INFO kablam! | Jul 11 19:16:42.825 INFO kablam! 11 | use bincode; Jul 11 19:16:42.825 INFO kablam! | ^^^^^^^ Jul 11 19:16:42.825 INFO kablam! Jul 11 19:16:42.825 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Jul 11 19:16:42.825 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:13:25 Jul 11 19:16:42.826 INFO kablam! | Jul 11 19:16:42.826 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:42.826 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:42.826 INFO kablam! Jul 11 19:16:42.826 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Jul 11 19:16:42.826 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:16:21 Jul 11 19:16:42.826 INFO kablam! | Jul 11 19:16:42.827 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:42.827 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.827 INFO kablam! Jul 11 19:16:42.827 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:42.827 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:19:13 Jul 11 19:16:42.827 INFO kablam! | Jul 11 19:16:42.827 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Jul 11 19:16:42.827 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:42.828 INFO kablam! Jul 11 19:16:42.917 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 Jul 11 19:16:42.917 INFO kablam! --> src/types.rs:3:5 Jul 11 19:16:42.917 INFO kablam! | Jul 11 19:16:42.917 INFO kablam! 3 | use futures::future::BoxFuture; Jul 11 19:16:42.917 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.917 INFO kablam! | Jul 11 19:16:42.917 INFO kablam! = note: #[warn(deprecated)] on by default Jul 11 19:16:42.917 INFO kablam! Jul 11 19:16:42.917 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 Jul 11 19:16:42.917 INFO kablam! --> src/types.rs:5:5 Jul 11 19:16:42.918 INFO kablam! | Jul 11 19:16:42.918 INFO kablam! 5 | use futures::stream::BoxStream; Jul 11 19:16:42.918 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.918 INFO kablam! Jul 11 19:16:42.918 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 Jul 11 19:16:42.918 INFO kablam! --> src/types.rs:7:29 Jul 11 19:16:42.918 INFO kablam! | Jul 11 19:16:42.918 INFO kablam! 7 | pub type BoxMqttFuture = BoxFuture; Jul 11 19:16:42.918 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.918 INFO kablam! Jul 11 19:16:42.918 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 Jul 11 19:16:42.918 INFO kablam! --> src/types.rs:9:29 Jul 11 19:16:42.918 INFO kablam! | Jul 11 19:16:42.918 INFO kablam! 9 | pub type BoxMqttStream = BoxStream; Jul 11 19:16:42.918 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.918 INFO kablam! Jul 11 19:16:42.919 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Jul 11 19:16:42.920 INFO kablam! --> src/tokio/mod.rs:12:5 Jul 11 19:16:42.920 INFO kablam! | Jul 11 19:16:42.920 INFO kablam! 12 | use tokio_io::codec::Framed; Jul 11 19:16:42.920 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.920 INFO kablam! Jul 11 19:16:42.920 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Jul 11 19:16:42.920 INFO kablam! --> src/tokio/mod.rs:27:40 Jul 11 19:16:42.920 INFO kablam! | Jul 11 19:16:42.920 INFO kablam! 27 | type MqttFramedReader = SplitStream>; Jul 11 19:16:42.920 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.920 INFO kablam! Jul 11 19:16:42.920 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Jul 11 19:16:42.920 INFO kablam! --> src/tokio/mod.rs:28:38 Jul 11 19:16:42.920 INFO kablam! | Jul 11 19:16:42.920 INFO kablam! 28 | type MqttFramedWriter = SplitSink>; Jul 11 19:16:42.920 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:42.920 INFO kablam! Jul 11 19:16:43.401 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:43.401 INFO kablam! --> src/errors.rs:4:1 Jul 11 19:16:43.401 INFO kablam! | Jul 11 19:16:43.401 INFO kablam! 4 | / error_chain! { Jul 11 19:16:43.401 INFO kablam! 5 | | links { Jul 11 19:16:43.401 INFO kablam! 6 | | Protocol(self::proto::Error, self::proto::ErrorKind); Jul 11 19:16:43.401 INFO kablam! 7 | | } Jul 11 19:16:43.401 INFO kablam! ... | Jul 11 19:16:43.401 INFO kablam! 66 | | } Jul 11 19:16:43.401 INFO kablam! 67 | | } Jul 11 19:16:43.401 INFO kablam! | |_^ Jul 11 19:16:43.401 INFO kablam! | Jul 11 19:16:43.401 INFO kablam! = note: #[warn(renamed_and_removed_lints)] on by default Jul 11 19:16:43.401 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:43.402 INFO kablam! Jul 11 19:16:43.402 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:43.402 INFO kablam! --> src/errors.rs:4:1 Jul 11 19:16:43.402 INFO kablam! | Jul 11 19:16:43.402 INFO kablam! 4 | / error_chain! { Jul 11 19:16:43.402 INFO kablam! 5 | | links { Jul 11 19:16:43.402 INFO kablam! 6 | | Protocol(self::proto::Error, self::proto::ErrorKind); Jul 11 19:16:43.402 INFO kablam! 7 | | } Jul 11 19:16:43.402 INFO kablam! ... | Jul 11 19:16:43.402 INFO kablam! 66 | | } Jul 11 19:16:43.403 INFO kablam! 67 | | } Jul 11 19:16:43.403 INFO kablam! | |_^ Jul 11 19:16:43.403 INFO kablam! | Jul 11 19:16:43.403 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:43.403 INFO kablam! Jul 11 19:16:43.406 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:43.406 INFO kablam! --> src/errors.rs:4:1 Jul 11 19:16:43.406 INFO kablam! | Jul 11 19:16:43.406 INFO kablam! 4 | / error_chain! { Jul 11 19:16:43.406 INFO kablam! 5 | | links { Jul 11 19:16:43.406 INFO kablam! 6 | | Protocol(self::proto::Error, self::proto::ErrorKind); Jul 11 19:16:43.406 INFO kablam! 7 | | } Jul 11 19:16:43.406 INFO kablam! ... | Jul 11 19:16:43.406 INFO kablam! 66 | | } Jul 11 19:16:43.406 INFO kablam! 67 | | } Jul 11 19:16:43.406 INFO kablam! | |_^ Jul 11 19:16:43.406 INFO kablam! | Jul 11 19:16:43.406 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:43.406 INFO kablam! Jul 11 19:16:43.406 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:43.406 INFO kablam! --> src/errors.rs:4:1 Jul 11 19:16:43.406 INFO kablam! | Jul 11 19:16:43.406 INFO kablam! 4 | / error_chain! { Jul 11 19:16:43.406 INFO kablam! 5 | | links { Jul 11 19:16:43.407 INFO kablam! 6 | | Protocol(self::proto::Error, self::proto::ErrorKind); Jul 11 19:16:43.407 INFO kablam! 7 | | } Jul 11 19:16:43.407 INFO kablam! ... | Jul 11 19:16:43.407 INFO kablam! 66 | | } Jul 11 19:16:43.407 INFO kablam! 67 | | } Jul 11 19:16:43.407 INFO kablam! | |_^ Jul 11 19:16:43.407 INFO kablam! | Jul 11 19:16:43.407 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:43.407 INFO kablam! Jul 11 19:16:43.407 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:43.407 INFO kablam! --> src/errors.rs:77:5 Jul 11 19:16:43.407 INFO kablam! | Jul 11 19:16:43.407 INFO kablam! 77 | / error_chain!{ Jul 11 19:16:43.407 INFO kablam! 78 | | errors { Jul 11 19:16:43.407 INFO kablam! 79 | | ResponseTimeout(p: PacketType) { Jul 11 19:16:43.407 INFO kablam! 80 | | description("Timeout waiting for server response") Jul 11 19:16:43.407 INFO kablam! ... | Jul 11 19:16:43.407 INFO kablam! 108 | | } Jul 11 19:16:43.407 INFO kablam! 109 | | } Jul 11 19:16:43.407 INFO kablam! | |_____^ Jul 11 19:16:43.407 INFO kablam! | Jul 11 19:16:43.407 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:43.407 INFO kablam! Jul 11 19:16:43.409 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:43.409 INFO kablam! --> src/errors.rs:77:5 Jul 11 19:16:43.409 INFO kablam! | Jul 11 19:16:43.409 INFO kablam! 77 | / error_chain!{ Jul 11 19:16:43.409 INFO kablam! 78 | | errors { Jul 11 19:16:43.409 INFO kablam! 79 | | ResponseTimeout(p: PacketType) { Jul 11 19:16:43.409 INFO kablam! 80 | | description("Timeout waiting for server response") Jul 11 19:16:43.409 INFO kablam! ... | Jul 11 19:16:43.409 INFO kablam! 108 | | } Jul 11 19:16:43.409 INFO kablam! 109 | | } Jul 11 19:16:43.409 INFO kablam! | |_____^ Jul 11 19:16:43.409 INFO kablam! | Jul 11 19:16:43.409 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:43.409 INFO kablam! Jul 11 19:16:43.409 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:43.409 INFO kablam! --> src/errors.rs:77:5 Jul 11 19:16:43.409 INFO kablam! | Jul 11 19:16:43.410 INFO kablam! 77 | / error_chain!{ Jul 11 19:16:43.410 INFO kablam! 78 | | errors { Jul 11 19:16:43.410 INFO kablam! 79 | | ResponseTimeout(p: PacketType) { Jul 11 19:16:43.410 INFO kablam! 80 | | description("Timeout waiting for server response") Jul 11 19:16:43.410 INFO kablam! ... | Jul 11 19:16:43.410 INFO kablam! 108 | | } Jul 11 19:16:43.410 INFO kablam! 109 | | } Jul 11 19:16:43.410 INFO kablam! | |_____^ Jul 11 19:16:43.410 INFO kablam! | Jul 11 19:16:43.410 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:43.410 INFO kablam! Jul 11 19:16:43.412 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:43.412 INFO kablam! --> src/errors.rs:77:5 Jul 11 19:16:43.413 INFO kablam! | Jul 11 19:16:43.413 INFO kablam! 77 | / error_chain!{ Jul 11 19:16:43.413 INFO kablam! 78 | | errors { Jul 11 19:16:43.413 INFO kablam! 79 | | ResponseTimeout(p: PacketType) { Jul 11 19:16:43.413 INFO kablam! 80 | | description("Timeout waiting for server response") Jul 11 19:16:43.413 INFO kablam! ... | Jul 11 19:16:43.413 INFO kablam! 108 | | } Jul 11 19:16:43.413 INFO kablam! 109 | | } Jul 11 19:16:43.414 INFO kablam! | |_____^ Jul 11 19:16:43.414 INFO kablam! | Jul 11 19:16:43.414 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:43.414 INFO kablam! Jul 11 19:16:43.414 INFO kablam! warning: unused import: `Error` Jul 11 19:16:43.414 INFO kablam! --> src/proto/types.rs:4:14 Jul 11 19:16:43.414 INFO kablam! | Jul 11 19:16:43.414 INFO kablam! 4 | use errors::{Error, ErrorKind}; Jul 11 19:16:43.415 INFO kablam! | ^^^^^ Jul 11 19:16:43.415 INFO kablam! | Jul 11 19:16:43.415 INFO kablam! = note: #[warn(unused_imports)] on by default Jul 11 19:16:43.415 INFO kablam! Jul 11 19:16:43.415 INFO kablam! warning: unused import: `linked_hash_map::LinkedHashMap` Jul 11 19:16:43.415 INFO kablam! --> src/proto/types.rs:5:5 Jul 11 19:16:43.416 INFO kablam! | Jul 11 19:16:43.416 INFO kablam! 5 | use linked_hash_map::LinkedHashMap; Jul 11 19:16:43.416 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.416 INFO kablam! Jul 11 19:16:43.440 INFO kablam! warning: unused imports: `IResult`, `be_u16` Jul 11 19:16:43.440 INFO kablam! --> src/proto/headers.rs:3:11 Jul 11 19:16:43.441 INFO kablam! | Jul 11 19:16:43.441 INFO kablam! 3 | use nom::{IResult, be_u16}; Jul 11 19:16:43.441 INFO kablam! | ^^^^^^^ ^^^^^^ Jul 11 19:16:43.441 INFO kablam! Jul 11 19:16:43.441 INFO kablam! warning: unused import: `std::io` Jul 11 19:16:43.441 INFO kablam! --> src/proto/mod.rs:8:5 Jul 11 19:16:43.441 INFO kablam! | Jul 11 19:16:43.441 INFO kablam! 8 | use std::io; Jul 11 19:16:43.442 INFO kablam! | ^^^^^^^ Jul 11 19:16:43.442 INFO kablam! Jul 11 19:16:43.442 INFO kablam! warning: unused import: `Entry` Jul 11 19:16:43.442 INFO kablam! --> src/proto/mod.rs:12:23 Jul 11 19:16:43.442 INFO kablam! | Jul 11 19:16:43.442 INFO kablam! 12 | use linked_hash_map::{Entry,LinkedHashMap}; Jul 11 19:16:43.442 INFO kablam! | ^^^^^ Jul 11 19:16:43.442 INFO kablam! Jul 11 19:16:43.443 INFO kablam! warning: unused import: `Writer` Jul 11 19:16:43.443 INFO kablam! --> src/proto/mod.rs:13:38 Jul 11 19:16:43.443 INFO kablam! | Jul 11 19:16:43.443 INFO kablam! 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Jul 11 19:16:43.443 INFO kablam! | ^^^^^^ Jul 11 19:16:43.443 INFO kablam! Jul 11 19:16:43.443 INFO kablam! warning: unused import: `self::headers::*` Jul 11 19:16:43.443 INFO kablam! --> src/proto/mod.rs:15:5 Jul 11 19:16:43.443 INFO kablam! | Jul 11 19:16:43.443 INFO kablam! 15 | use self::headers::*; Jul 11 19:16:43.443 INFO kablam! | ^^^^^^^^^^^^^^^^ Jul 11 19:16:43.443 INFO kablam! Jul 11 19:16:43.447 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:43.447 INFO kablam! --> src/tokio/mqtt_loop.rs:13:5 Jul 11 19:16:43.447 INFO kablam! | Jul 11 19:16:43.447 INFO kablam! 13 | use take::Take; Jul 11 19:16:43.447 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.453 INFO kablam! Jul 11 19:16:43.453 INFO kablam! warning: unused import: `MqttFramedWriter` Jul 11 19:16:43.453 INFO kablam! --> src/tokio/mqtt_loop.rs:21:13 Jul 11 19:16:43.453 INFO kablam! | Jul 11 19:16:43.453 INFO kablam! 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Jul 11 19:16:43.454 INFO kablam! | ^^^^^^^^^^^^^^^^ Jul 11 19:16:43.454 INFO kablam! Jul 11 19:16:43.454 INFO kablam! warning: unused import: `super::response::ResponseProcessor` Jul 11 19:16:43.454 INFO kablam! --> src/tokio/mqtt_loop.rs:23:5 Jul 11 19:16:43.454 INFO kablam! | Jul 11 19:16:43.454 INFO kablam! 23 | use super::response::ResponseProcessor; Jul 11 19:16:43.454 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.454 INFO kablam! Jul 11 19:16:43.454 INFO kablam! warning: unused import: `super::request::RequestProcessor` Jul 11 19:16:43.454 INFO kablam! --> src/tokio/mqtt_loop.rs:24:5 Jul 11 19:16:43.454 INFO kablam! | Jul 11 19:16:43.454 INFO kablam! 24 | use super::request::RequestProcessor; Jul 11 19:16:43.454 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.454 INFO kablam! Jul 11 19:16:43.454 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:43.454 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:1:16 Jul 11 19:16:43.454 INFO kablam! | Jul 11 19:16:43.454 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:43.454 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:43.454 INFO kablam! Jul 11 19:16:43.454 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Jul 11 19:16:43.454 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:2:28 Jul 11 19:16:43.454 INFO kablam! | Jul 11 19:16:43.455 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Jul 11 19:16:43.455 INFO kablam! | ^^^^^^^^^ ^^^^ Jul 11 19:16:43.455 INFO kablam! Jul 11 19:16:43.455 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:43.455 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:4:5 Jul 11 19:16:43.455 INFO kablam! | Jul 11 19:16:43.455 INFO kablam! 4 | use take::Take; Jul 11 19:16:43.455 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.455 INFO kablam! Jul 11 19:16:43.455 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:43.455 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:6:5 Jul 11 19:16:43.455 INFO kablam! | Jul 11 19:16:43.455 INFO kablam! 6 | use bincode; Jul 11 19:16:43.455 INFO kablam! | ^^^^^^^ Jul 11 19:16:43.455 INFO kablam! Jul 11 19:16:43.455 INFO kablam! warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Jul 11 19:16:43.455 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:9:25 Jul 11 19:16:43.455 INFO kablam! | Jul 11 19:16:43.455 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Jul 11 19:16:43.455 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Jul 11 19:16:43.455 INFO kablam! Jul 11 19:16:43.455 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt` Jul 11 19:16:43.455 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:10:29 Jul 11 19:16:43.455 INFO kablam! | Jul 11 19:16:43.455 INFO kablam! 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:43.456 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.456 INFO kablam! Jul 11 19:16:43.456 INFO kablam! warning: unused import: `PublishState` Jul 11 19:16:43.456 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:12:25 Jul 11 19:16:43.456 INFO kablam! | Jul 11 19:16:43.456 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Jul 11 19:16:43.456 INFO kablam! | ^^^^^^^^^^^^ Jul 11 19:16:43.456 INFO kablam! Jul 11 19:16:43.458 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:43.458 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:1:16 Jul 11 19:16:43.458 INFO kablam! | Jul 11 19:16:43.458 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:43.458 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:43.458 INFO kablam! Jul 11 19:16:43.458 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Jul 11 19:16:43.458 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:2:28 Jul 11 19:16:43.458 INFO kablam! | Jul 11 19:16:43.458 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Jul 11 19:16:43.458 INFO kablam! | ^^^^^^^^^ ^^^^ Jul 11 19:16:43.458 INFO kablam! Jul 11 19:16:43.458 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:43.458 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:4:5 Jul 11 19:16:43.458 INFO kablam! | Jul 11 19:16:43.458 INFO kablam! 4 | use take::Take; Jul 11 19:16:43.458 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.458 INFO kablam! Jul 11 19:16:43.458 INFO kablam! warning: unused import: `PacketType` Jul 11 19:16:43.458 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:9:25 Jul 11 19:16:43.458 INFO kablam! | Jul 11 19:16:43.459 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Jul 11 19:16:43.459 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.459 INFO kablam! Jul 11 19:16:43.459 INFO kablam! warning: unused import: `OneTimeKey` Jul 11 19:16:43.459 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:12:13 Jul 11 19:16:43.459 INFO kablam! | Jul 11 19:16:43.459 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Jul 11 19:16:43.459 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.459 INFO kablam! Jul 11 19:16:43.460 INFO kablam! warning: unused import: `BoxFuture` Jul 11 19:16:43.460 INFO kablam! --> src/tokio/outbound_handlers/mod.rs:8:27 Jul 11 19:16:43.460 INFO kablam! | Jul 11 19:16:43.460 INFO kablam! 8 | use tokio::{RequestTuple, BoxFuture}; Jul 11 19:16:43.460 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:43.460 INFO kablam! Jul 11 19:16:43.460 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:43.460 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Jul 11 19:16:43.460 INFO kablam! | Jul 11 19:16:43.460 INFO kablam! 3 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:43.460 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:43.460 INFO kablam! Jul 11 19:16:43.460 INFO kablam! warning: unused import: `AsyncSink` Jul 11 19:16:43.460 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Jul 11 19:16:43.460 INFO kablam! | Jul 11 19:16:43.460 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:43.460 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:43.460 INFO kablam! Jul 11 19:16:43.461 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Jul 11 19:16:43.461 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Jul 11 19:16:43.461 INFO kablam! | Jul 11 19:16:43.462 INFO kablam! 6 | use futures::unsync::mpsc::UnboundedSender; Jul 11 19:16:43.462 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.462 INFO kablam! Jul 11 19:16:43.462 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:43.462 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Jul 11 19:16:43.462 INFO kablam! | Jul 11 19:16:43.462 INFO kablam! 7 | use take::Take; Jul 11 19:16:43.462 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.463 INFO kablam! Jul 11 19:16:43.463 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:43.463 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Jul 11 19:16:43.463 INFO kablam! | Jul 11 19:16:43.463 INFO kablam! 9 | use bincode; Jul 11 19:16:43.463 INFO kablam! | ^^^^^^^ Jul 11 19:16:43.463 INFO kablam! Jul 11 19:16:43.463 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Jul 11 19:16:43.464 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Jul 11 19:16:43.464 INFO kablam! | Jul 11 19:16:43.464 INFO kablam! 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:43.464 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:43.464 INFO kablam! 12 | PacketId, TopicName}; Jul 11 19:16:43.464 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:43.464 INFO kablam! Jul 11 19:16:43.464 INFO kablam! warning: unused imports: `ResultExt`, `Result` Jul 11 19:16:43.465 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Jul 11 19:16:43.465 INFO kablam! | Jul 11 19:16:43.465 INFO kablam! 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:43.465 INFO kablam! | ^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.465 INFO kablam! Jul 11 19:16:43.465 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Jul 11 19:16:43.465 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Jul 11 19:16:43.465 INFO kablam! | Jul 11 19:16:43.466 INFO kablam! 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Jul 11 19:16:43.466 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.466 INFO kablam! Jul 11 19:16:43.466 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:43.466 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Jul 11 19:16:43.466 INFO kablam! | Jul 11 19:16:43.466 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:43.467 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:43.467 INFO kablam! Jul 11 19:16:43.467 INFO kablam! warning: unused import: `AsyncSink` Jul 11 19:16:43.467 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Jul 11 19:16:43.467 INFO kablam! | Jul 11 19:16:43.467 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:43.467 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:43.467 INFO kablam! Jul 11 19:16:43.468 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:43.468 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Jul 11 19:16:43.468 INFO kablam! | Jul 11 19:16:43.468 INFO kablam! 6 | use futures::sync::mpsc::unbounded; Jul 11 19:16:43.468 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.468 INFO kablam! Jul 11 19:16:43.468 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Jul 11 19:16:43.468 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Jul 11 19:16:43.469 INFO kablam! | Jul 11 19:16:43.469 INFO kablam! 7 | use futures::unsync::mpsc::UnboundedSender; Jul 11 19:16:43.469 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.469 INFO kablam! Jul 11 19:16:43.469 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:43.469 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Jul 11 19:16:43.469 INFO kablam! | Jul 11 19:16:43.469 INFO kablam! 8 | use take::Take; Jul 11 19:16:43.470 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.470 INFO kablam! Jul 11 19:16:43.470 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:43.470 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Jul 11 19:16:43.470 INFO kablam! | Jul 11 19:16:43.470 INFO kablam! 10 | use bincode; Jul 11 19:16:43.470 INFO kablam! | ^^^^^^^ Jul 11 19:16:43.470 INFO kablam! Jul 11 19:16:43.471 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Jul 11 19:16:43.471 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Jul 11 19:16:43.471 INFO kablam! | Jul 11 19:16:43.471 INFO kablam! 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:43.471 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:43.471 INFO kablam! 13 | PacketId, TopicName}; Jul 11 19:16:43.471 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:43.471 INFO kablam! Jul 11 19:16:43.472 INFO kablam! warning: unused imports: `ResultExt`, `Result` Jul 11 19:16:43.472 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Jul 11 19:16:43.472 INFO kablam! | Jul 11 19:16:43.472 INFO kablam! 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:43.472 INFO kablam! | ^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.472 INFO kablam! Jul 11 19:16:43.472 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:43.472 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Jul 11 19:16:43.473 INFO kablam! | Jul 11 19:16:43.473 INFO kablam! 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Jul 11 19:16:43.473 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.473 INFO kablam! Jul 11 19:16:43.473 INFO kablam! warning: unused import: `std::ops::Deref` Jul 11 19:16:43.473 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:2:5 Jul 11 19:16:43.473 INFO kablam! | Jul 11 19:16:43.473 INFO kablam! 2 | use std::ops::Deref; Jul 11 19:16:43.473 INFO kablam! | ^^^^^^^^^^^^^^^ Jul 11 19:16:43.473 INFO kablam! Jul 11 19:16:43.474 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:43.474 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:4:16 Jul 11 19:16:43.474 INFO kablam! | Jul 11 19:16:43.474 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:43.474 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:43.474 INFO kablam! Jul 11 19:16:43.474 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Jul 11 19:16:43.474 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:15 Jul 11 19:16:43.474 INFO kablam! | Jul 11 19:16:43.474 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:43.474 INFO kablam! | ^^^^ ^^^^^^^^^ Jul 11 19:16:43.474 INFO kablam! Jul 11 19:16:43.474 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:43.474 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:7:5 Jul 11 19:16:43.474 INFO kablam! | Jul 11 19:16:43.474 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Jul 11 19:16:43.474 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.474 INFO kablam! Jul 11 19:16:43.474 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Jul 11 19:16:43.474 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:8:5 Jul 11 19:16:43.474 INFO kablam! | Jul 11 19:16:43.474 INFO kablam! 8 | use futures::unsync::mpsc::UnboundedSender; Jul 11 19:16:43.475 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.475 INFO kablam! Jul 11 19:16:43.475 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:43.475 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:9:5 Jul 11 19:16:43.475 INFO kablam! | Jul 11 19:16:43.475 INFO kablam! 9 | use take::Take; Jul 11 19:16:43.475 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.475 INFO kablam! Jul 11 19:16:43.475 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:43.475 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:11:5 Jul 11 19:16:43.475 INFO kablam! | Jul 11 19:16:43.475 INFO kablam! 11 | use bincode; Jul 11 19:16:43.475 INFO kablam! | ^^^^^^^ Jul 11 19:16:43.475 INFO kablam! Jul 11 19:16:43.475 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Jul 11 19:16:43.475 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:13:13 Jul 11 19:16:43.475 INFO kablam! | Jul 11 19:16:43.475 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:43.475 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:43.475 INFO kablam! 14 | PacketId, TopicName}; Jul 11 19:16:43.475 INFO kablam! | ^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.475 INFO kablam! Jul 11 19:16:43.475 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Jul 11 19:16:43.475 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:16:21 Jul 11 19:16:43.475 INFO kablam! | Jul 11 19:16:43.476 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:43.476 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.476 INFO kablam! Jul 11 19:16:43.476 INFO kablam! warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Jul 11 19:16:43.476 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:17:5 Jul 11 19:16:43.476 INFO kablam! | Jul 11 19:16:43.476 INFO kablam! 17 | use errors::proto::ErrorKind as ProtoErrorKind; Jul 11 19:16:43.476 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.476 INFO kablam! Jul 11 19:16:43.476 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:43.476 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:19:25 Jul 11 19:16:43.476 INFO kablam! | Jul 11 19:16:43.476 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Jul 11 19:16:43.476 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.476 INFO kablam! Jul 11 19:16:43.476 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Jul 11 19:16:43.476 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:1:5 Jul 11 19:16:43.476 INFO kablam! | Jul 11 19:16:43.476 INFO kablam! 1 | use std::collections::hash_map::Entry; Jul 11 19:16:43.476 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.476 INFO kablam! Jul 11 19:16:43.476 INFO kablam! warning: unused import: `std::ops::Deref` Jul 11 19:16:43.476 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:2:5 Jul 11 19:16:43.476 INFO kablam! | Jul 11 19:16:43.476 INFO kablam! 2 | use std::ops::Deref; Jul 11 19:16:43.476 INFO kablam! | ^^^^^^^^^^^^^^^ Jul 11 19:16:43.476 INFO kablam! Jul 11 19:16:43.477 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:43.477 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:5:16 Jul 11 19:16:43.477 INFO kablam! | Jul 11 19:16:43.477 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:43.477 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:43.477 INFO kablam! Jul 11 19:16:43.477 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Jul 11 19:16:43.477 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:28 Jul 11 19:16:43.477 INFO kablam! | Jul 11 19:16:43.477 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:43.477 INFO kablam! | ^^^^^^^^^ ^^^^ Jul 11 19:16:43.477 INFO kablam! Jul 11 19:16:43.477 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:43.477 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:7:5 Jul 11 19:16:43.477 INFO kablam! | Jul 11 19:16:43.477 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Jul 11 19:16:43.477 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.477 INFO kablam! Jul 11 19:16:43.477 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:43.477 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:9:5 Jul 11 19:16:43.477 INFO kablam! | Jul 11 19:16:43.477 INFO kablam! 9 | use take::Take; Jul 11 19:16:43.477 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.477 INFO kablam! Jul 11 19:16:43.477 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:43.477 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:11:5 Jul 11 19:16:43.478 INFO kablam! | Jul 11 19:16:43.478 INFO kablam! 11 | use bincode; Jul 11 19:16:43.478 INFO kablam! | ^^^^^^^ Jul 11 19:16:43.478 INFO kablam! Jul 11 19:16:43.478 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Jul 11 19:16:43.478 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:13:25 Jul 11 19:16:43.478 INFO kablam! | Jul 11 19:16:43.478 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:43.478 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:43.478 INFO kablam! Jul 11 19:16:43.482 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Jul 11 19:16:43.482 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:16:21 Jul 11 19:16:43.482 INFO kablam! | Jul 11 19:16:43.482 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:43.482 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.483 INFO kablam! Jul 11 19:16:43.483 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:43.483 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:19:13 Jul 11 19:16:43.483 INFO kablam! | Jul 11 19:16:43.483 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Jul 11 19:16:43.483 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.483 INFO kablam! Jul 11 19:16:43.483 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Jul 11 19:16:43.483 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Jul 11 19:16:43.484 INFO kablam! | Jul 11 19:16:43.484 INFO kablam! 1 | use std::collections::hash_map::Entry; Jul 11 19:16:43.484 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.484 INFO kablam! Jul 11 19:16:43.484 INFO kablam! warning: unused import: `std::ops::Deref` Jul 11 19:16:43.484 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Jul 11 19:16:43.484 INFO kablam! | Jul 11 19:16:43.484 INFO kablam! 2 | use std::ops::Deref; Jul 11 19:16:43.484 INFO kablam! | ^^^^^^^^^^^^^^^ Jul 11 19:16:43.488 INFO kablam! Jul 11 19:16:43.489 INFO kablam! warning: unused import: `bytes::Bytes` Jul 11 19:16:43.489 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Jul 11 19:16:43.489 INFO kablam! | Jul 11 19:16:43.489 INFO kablam! 4 | use bytes::Bytes; Jul 11 19:16:43.489 INFO kablam! | ^^^^^^^^^^^^ Jul 11 19:16:43.489 INFO kablam! Jul 11 19:16:43.490 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:43.490 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Jul 11 19:16:43.490 INFO kablam! | Jul 11 19:16:43.490 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:43.490 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:43.490 INFO kablam! Jul 11 19:16:43.490 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Jul 11 19:16:43.490 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Jul 11 19:16:43.491 INFO kablam! | Jul 11 19:16:43.494 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:43.494 INFO kablam! | ^^^^ ^^^^^^^^^ Jul 11 19:16:43.494 INFO kablam! Jul 11 19:16:43.494 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:43.495 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Jul 11 19:16:43.495 INFO kablam! | Jul 11 19:16:43.495 INFO kablam! 8 | use futures::sync::mpsc::unbounded; Jul 11 19:16:43.495 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.495 INFO kablam! Jul 11 19:16:43.495 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Jul 11 19:16:43.495 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Jul 11 19:16:43.495 INFO kablam! | Jul 11 19:16:43.496 INFO kablam! 9 | use futures::unsync::mpsc::UnboundedSender; Jul 11 19:16:43.496 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.496 INFO kablam! Jul 11 19:16:43.496 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:43.496 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Jul 11 19:16:43.496 INFO kablam! | Jul 11 19:16:43.496 INFO kablam! 10 | use take::Take; Jul 11 19:16:43.496 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.497 INFO kablam! Jul 11 19:16:43.497 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:43.497 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Jul 11 19:16:43.497 INFO kablam! | Jul 11 19:16:43.497 INFO kablam! 12 | use bincode; Jul 11 19:16:43.497 INFO kablam! | ^^^^^^^ Jul 11 19:16:43.497 INFO kablam! Jul 11 19:16:43.497 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Jul 11 19:16:43.498 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Jul 11 19:16:43.498 INFO kablam! | Jul 11 19:16:43.498 INFO kablam! 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:43.498 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:43.498 INFO kablam! 15 | PacketId, TopicName}; Jul 11 19:16:43.498 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:43.498 INFO kablam! Jul 11 19:16:43.499 INFO kablam! warning: unused import: `Result` Jul 11 19:16:43.499 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Jul 11 19:16:43.499 INFO kablam! | Jul 11 19:16:43.499 INFO kablam! 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:43.499 INFO kablam! | ^^^^^^ Jul 11 19:16:43.499 INFO kablam! Jul 11 19:16:43.499 INFO kablam! warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:43.499 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Jul 11 19:16:43.500 INFO kablam! | Jul 11 19:16:43.500 INFO kablam! 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Jul 11 19:16:43.500 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.500 INFO kablam! Jul 11 19:16:43.500 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Jul 11 19:16:43.500 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Jul 11 19:16:43.502 INFO kablam! | Jul 11 19:16:43.502 INFO kablam! 1 | use std::collections::hash_map::Entry; Jul 11 19:16:43.502 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.503 INFO kablam! Jul 11 19:16:43.503 INFO kablam! warning: unused import: `std::ops::Deref` Jul 11 19:16:43.503 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Jul 11 19:16:43.503 INFO kablam! | Jul 11 19:16:43.503 INFO kablam! 2 | use std::ops::Deref; Jul 11 19:16:43.503 INFO kablam! | ^^^^^^^^^^^^^^^ Jul 11 19:16:43.503 INFO kablam! Jul 11 19:16:43.503 INFO kablam! warning: unused import: `bytes::Bytes` Jul 11 19:16:43.504 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Jul 11 19:16:43.504 INFO kablam! | Jul 11 19:16:43.504 INFO kablam! 4 | use bytes::Bytes; Jul 11 19:16:43.504 INFO kablam! | ^^^^^^^^^^^^ Jul 11 19:16:43.504 INFO kablam! Jul 11 19:16:43.504 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:43.504 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Jul 11 19:16:43.504 INFO kablam! | Jul 11 19:16:43.504 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:43.505 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:43.505 INFO kablam! Jul 11 19:16:43.505 INFO kablam! warning: unused import: `AsyncSink` Jul 11 19:16:43.505 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Jul 11 19:16:43.505 INFO kablam! | Jul 11 19:16:43.505 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:43.505 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:43.505 INFO kablam! Jul 11 19:16:43.505 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:43.506 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Jul 11 19:16:43.506 INFO kablam! | Jul 11 19:16:43.506 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Jul 11 19:16:43.506 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.506 INFO kablam! Jul 11 19:16:43.506 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:43.506 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Jul 11 19:16:43.506 INFO kablam! | Jul 11 19:16:43.507 INFO kablam! 9 | use take::Take; Jul 11 19:16:43.507 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.507 INFO kablam! Jul 11 19:16:43.507 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Jul 11 19:16:43.507 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Jul 11 19:16:43.507 INFO kablam! | Jul 11 19:16:43.507 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:43.507 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:43.508 INFO kablam! 14 | PacketId, TopicName}; Jul 11 19:16:43.508 INFO kablam! | ^^^^^^^^^ Jul 11 19:16:43.508 INFO kablam! Jul 11 19:16:43.508 INFO kablam! warning: unused import: `Result` Jul 11 19:16:43.508 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Jul 11 19:16:43.508 INFO kablam! | Jul 11 19:16:43.508 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:43.508 INFO kablam! | ^^^^^^ Jul 11 19:16:43.509 INFO kablam! Jul 11 19:16:43.509 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:43.509 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Jul 11 19:16:43.509 INFO kablam! | Jul 11 19:16:43.509 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Jul 11 19:16:43.509 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.509 INFO kablam! Jul 11 19:16:43.509 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Jul 11 19:16:43.509 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:1:5 Jul 11 19:16:43.510 INFO kablam! | Jul 11 19:16:43.510 INFO kablam! 1 | use std::collections::hash_map::Entry; Jul 11 19:16:43.510 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.510 INFO kablam! Jul 11 19:16:43.510 INFO kablam! warning: unused import: `std::ops::Deref` Jul 11 19:16:43.510 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:2:5 Jul 11 19:16:43.510 INFO kablam! | Jul 11 19:16:43.510 INFO kablam! 2 | use std::ops::Deref; Jul 11 19:16:43.510 INFO kablam! | ^^^^^^^^^^^^^^^ Jul 11 19:16:43.511 INFO kablam! Jul 11 19:16:43.511 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Jul 11 19:16:43.511 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:5:16 Jul 11 19:16:43.511 INFO kablam! | Jul 11 19:16:43.511 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Jul 11 19:16:43.511 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Jul 11 19:16:43.511 INFO kablam! Jul 11 19:16:43.511 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Jul 11 19:16:43.512 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:28 Jul 11 19:16:43.512 INFO kablam! | Jul 11 19:16:43.512 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:43.512 INFO kablam! | ^^^^^^^^^ ^^^^ Jul 11 19:16:43.512 INFO kablam! Jul 11 19:16:43.512 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Jul 11 19:16:43.512 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:7:5 Jul 11 19:16:43.512 INFO kablam! | Jul 11 19:16:43.512 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Jul 11 19:16:43.513 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.513 INFO kablam! Jul 11 19:16:43.513 INFO kablam! warning: unused import: `take::Take` Jul 11 19:16:43.515 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:9:5 Jul 11 19:16:43.515 INFO kablam! | Jul 11 19:16:43.515 INFO kablam! 9 | use take::Take; Jul 11 19:16:43.515 INFO kablam! | ^^^^^^^^^^ Jul 11 19:16:43.515 INFO kablam! Jul 11 19:16:43.515 INFO kablam! warning: unused import: `bincode` Jul 11 19:16:43.515 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:11:5 Jul 11 19:16:43.516 INFO kablam! | Jul 11 19:16:43.516 INFO kablam! 11 | use bincode; Jul 11 19:16:43.516 INFO kablam! | ^^^^^^^ Jul 11 19:16:43.516 INFO kablam! Jul 11 19:16:43.516 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Jul 11 19:16:43.516 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:13:25 Jul 11 19:16:43.516 INFO kablam! | Jul 11 19:16:43.516 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Jul 11 19:16:43.516 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Jul 11 19:16:43.516 INFO kablam! Jul 11 19:16:43.517 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Jul 11 19:16:43.517 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:16:21 Jul 11 19:16:43.517 INFO kablam! | Jul 11 19:16:43.517 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Jul 11 19:16:43.517 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.517 INFO kablam! Jul 11 19:16:43.517 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Jul 11 19:16:43.517 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:19:13 Jul 11 19:16:43.517 INFO kablam! | Jul 11 19:16:43.517 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Jul 11 19:16:43.518 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Jul 11 19:16:43.518 INFO kablam! Jul 11 19:16:43.681 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 Jul 11 19:16:43.681 INFO kablam! --> src/types.rs:3:5 Jul 11 19:16:43.681 INFO kablam! | Jul 11 19:16:43.681 INFO kablam! 3 | use futures::future::BoxFuture; Jul 11 19:16:43.681 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.681 INFO kablam! | Jul 11 19:16:43.681 INFO kablam! = note: #[warn(deprecated)] on by default Jul 11 19:16:43.682 INFO kablam! Jul 11 19:16:43.682 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 Jul 11 19:16:43.682 INFO kablam! --> src/types.rs:5:5 Jul 11 19:16:43.682 INFO kablam! | Jul 11 19:16:43.682 INFO kablam! 5 | use futures::stream::BoxStream; Jul 11 19:16:43.682 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.682 INFO kablam! Jul 11 19:16:43.682 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 Jul 11 19:16:43.682 INFO kablam! --> src/types.rs:7:29 Jul 11 19:16:43.682 INFO kablam! | Jul 11 19:16:43.682 INFO kablam! 7 | pub type BoxMqttFuture = BoxFuture; Jul 11 19:16:43.682 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.682 INFO kablam! Jul 11 19:16:43.682 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 Jul 11 19:16:43.682 INFO kablam! --> src/types.rs:9:29 Jul 11 19:16:43.682 INFO kablam! | Jul 11 19:16:43.683 INFO kablam! 9 | pub type BoxMqttStream = BoxStream; Jul 11 19:16:43.683 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.683 INFO kablam! Jul 11 19:16:43.684 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Jul 11 19:16:43.684 INFO kablam! --> src/tokio/mod.rs:12:5 Jul 11 19:16:43.684 INFO kablam! | Jul 11 19:16:43.684 INFO kablam! 12 | use tokio_io::codec::Framed; Jul 11 19:16:43.684 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.684 INFO kablam! Jul 11 19:16:43.684 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Jul 11 19:16:43.684 INFO kablam! --> src/tokio/mod.rs:27:40 Jul 11 19:16:43.684 INFO kablam! | Jul 11 19:16:43.684 INFO kablam! 27 | type MqttFramedReader = SplitStream>; Jul 11 19:16:43.684 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.684 INFO kablam! Jul 11 19:16:43.684 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Jul 11 19:16:43.684 INFO kablam! --> src/tokio/mod.rs:28:38 Jul 11 19:16:43.684 INFO kablam! | Jul 11 19:16:43.685 INFO kablam! 28 | type MqttFramedWriter = SplitSink>; Jul 11 19:16:43.685 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:43.685 INFO kablam! Jul 11 19:16:44.410 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Jul 11 19:16:44.410 INFO kablam! --> src/proto/types.rs:271:13 Jul 11 19:16:44.410 INFO kablam! | Jul 11 19:16:44.410 INFO kablam! 271 | out.put_u16::(self.len() as u16); Jul 11 19:16:44.410 INFO kablam! | ^^^^^^^ Jul 11 19:16:44.411 INFO kablam! Jul 11 19:16:44.968 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Jul 11 19:16:44.968 INFO kablam! --> src/proto/headers.rs:135:40 Jul 11 19:16:44.968 INFO kablam! | Jul 11 19:16:44.968 INFO kablam! 135 | Ok(PacketId(raw.into_buf().get_u16::())) Jul 11 19:16:44.969 INFO kablam! | ^^^^^^^ Jul 11 19:16:44.969 INFO kablam! Jul 11 19:16:44.969 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Jul 11 19:16:44.969 INFO kablam! --> src/proto/headers.rs:140:13 Jul 11 19:16:44.969 INFO kablam! | Jul 11 19:16:44.969 INFO kablam! 140 | out.put_u16::(self.0); Jul 11 19:16:44.969 INFO kablam! | ^^^^^^^ Jul 11 19:16:44.969 INFO kablam! Jul 11 19:16:44.972 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Jul 11 19:16:44.972 INFO kablam! --> src/proto/headers.rs:170:41 Jul 11 19:16:44.972 INFO kablam! | Jul 11 19:16:44.972 INFO kablam! 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Jul 11 19:16:44.972 INFO kablam! | ^^^^^^^ Jul 11 19:16:44.972 INFO kablam! Jul 11 19:16:44.973 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Jul 11 19:16:44.973 INFO kablam! --> src/proto/headers.rs:175:13 Jul 11 19:16:44.973 INFO kablam! | Jul 11 19:16:44.973 INFO kablam! 175 | out.put_u16::(self.0); Jul 11 19:16:44.973 INFO kablam! | ^^^^^^^ Jul 11 19:16:44.977 INFO kablam! Jul 11 19:16:45.042 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 Jul 11 19:16:45.042 INFO kablam! --> src/client.rs:223:55 Jul 11 19:16:45.042 INFO kablam! | Jul 11 19:16:45.042 INFO kablam! 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Jul 11 19:16:45.042 INFO kablam! | ^^^^^ Jul 11 19:16:45.042 INFO kablam! Jul 11 19:16:45.064 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 Jul 11 19:16:45.064 INFO kablam! --> src/client.rs:266:63 Jul 11 19:16:45.064 INFO kablam! | Jul 11 19:16:45.064 INFO kablam! 266 | client.request(connect).into_future().map(|_| ()).boxed() Jul 11 19:16:45.064 INFO kablam! | ^^^^^ Jul 11 19:16:45.064 INFO kablam! Jul 11 19:16:45.216 INFO kablam! warning: use of deprecated item '>::send': renamed to `unbounded_send` Jul 11 19:16:45.216 INFO kablam! --> src/tokio/mqtt_loop.rs:54:32 Jul 11 19:16:45.216 INFO kablam! | Jul 11 19:16:45.216 INFO kablam! 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Jul 11 19:16:45.216 INFO kablam! | ^^^^ Jul 11 19:16:45.216 INFO kablam! Jul 11 19:16:45.227 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 Jul 11 19:16:45.227 INFO kablam! --> src/tokio/mqtt_loop.rs:60:47 Jul 11 19:16:45.227 INFO kablam! | Jul 11 19:16:45.227 INFO kablam! 60 | Ok((next_state(sender), Ok(rx.boxed()))) Jul 11 19:16:45.227 INFO kablam! | ^^^^^ Jul 11 19:16:45.227 INFO kablam! Jul 11 19:16:45.274 INFO kablam! warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Jul 11 19:16:45.275 INFO kablam! --> src/tokio/mqtt_loop.rs:266:34 Jul 11 19:16:45.275 INFO kablam! | Jul 11 19:16:45.275 INFO kablam! 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Jul 11 19:16:45.275 INFO kablam! | ^^^^^^ Jul 11 19:16:45.275 INFO kablam! Jul 11 19:16:45.352 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Jul 11 19:16:45.352 INFO kablam! --> src/proto/types.rs:271:13 Jul 11 19:16:45.352 INFO kablam! | Jul 11 19:16:45.352 INFO kablam! 271 | out.put_u16::(self.len() as u16); Jul 11 19:16:45.352 INFO kablam! | ^^^^^^^ Jul 11 19:16:45.353 INFO kablam! Jul 11 19:16:45.365 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 Jul 11 19:16:45.365 INFO kablam! --> src/tokio/mqtt_loop.rs:317:14 Jul 11 19:16:45.365 INFO kablam! | Jul 11 19:16:45.365 INFO kablam! 317 | .boxed() Jul 11 19:16:45.365 INFO kablam! | ^^^^^ Jul 11 19:16:45.365 INFO kablam! Jul 11 19:16:45.421 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 Jul 11 19:16:45.421 INFO kablam! --> src/tokio/mqtt_loop.rs:519:42 Jul 11 19:16:45.421 INFO kablam! | Jul 11 19:16:45.421 INFO kablam! 519 | .boxed(), Jul 11 19:16:45.421 INFO kablam! | ^^^^^ Jul 11 19:16:45.421 INFO kablam! Jul 11 19:16:45.461 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 Jul 11 19:16:45.461 INFO kablam! --> src/tokio/response.rs:83:40 Jul 11 19:16:45.461 INFO kablam! | Jul 11 19:16:45.461 INFO kablam! 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Jul 11 19:16:45.461 INFO kablam! | ^^^^^ Jul 11 19:16:45.461 INFO kablam! Jul 11 19:16:45.674 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 Jul 11 19:16:45.674 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Jul 11 19:16:45.674 INFO kablam! | Jul 11 19:16:45.674 INFO kablam! 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Jul 11 19:16:45.675 INFO kablam! | ^^^^^ Jul 11 19:16:45.675 INFO kablam! Jul 11 19:16:45.761 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Jul 11 19:16:45.761 INFO kablam! --> src/proto/headers.rs:135:40 Jul 11 19:16:45.761 INFO kablam! | Jul 11 19:16:45.761 INFO kablam! 135 | Ok(PacketId(raw.into_buf().get_u16::())) Jul 11 19:16:45.761 INFO kablam! | ^^^^^^^ Jul 11 19:16:45.762 INFO kablam! Jul 11 19:16:45.763 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Jul 11 19:16:45.763 INFO kablam! --> src/proto/headers.rs:140:13 Jul 11 19:16:45.763 INFO kablam! | Jul 11 19:16:45.763 INFO kablam! 140 | out.put_u16::(self.0); Jul 11 19:16:45.763 INFO kablam! | ^^^^^^^ Jul 11 19:16:45.763 INFO kablam! Jul 11 19:16:45.765 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Jul 11 19:16:45.765 INFO kablam! --> src/proto/headers.rs:170:41 Jul 11 19:16:45.765 INFO kablam! | Jul 11 19:16:45.765 INFO kablam! 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Jul 11 19:16:45.765 INFO kablam! | ^^^^^^^ Jul 11 19:16:45.766 INFO kablam! Jul 11 19:16:45.766 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Jul 11 19:16:45.766 INFO kablam! --> src/proto/headers.rs:175:13 Jul 11 19:16:45.766 INFO kablam! | Jul 11 19:16:45.766 INFO kablam! 175 | out.put_u16::(self.0); Jul 11 19:16:45.766 INFO kablam! | ^^^^^^^ Jul 11 19:16:45.766 INFO kablam! Jul 11 19:16:45.818 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 Jul 11 19:16:45.818 INFO kablam! --> src/client.rs:223:55 Jul 11 19:16:45.818 INFO kablam! | Jul 11 19:16:45.818 INFO kablam! 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Jul 11 19:16:45.818 INFO kablam! | ^^^^^ Jul 11 19:16:45.818 INFO kablam! Jul 11 19:16:45.841 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 Jul 11 19:16:45.841 INFO kablam! --> src/client.rs:266:63 Jul 11 19:16:45.841 INFO kablam! | Jul 11 19:16:45.841 INFO kablam! 266 | client.request(connect).into_future().map(|_| ()).boxed() Jul 11 19:16:45.842 INFO kablam! | ^^^^^ Jul 11 19:16:45.842 INFO kablam! Jul 11 19:16:45.971 INFO kablam! warning: use of deprecated item '>::send': renamed to `unbounded_send` Jul 11 19:16:45.971 INFO kablam! --> src/tokio/mqtt_loop.rs:54:32 Jul 11 19:16:45.971 INFO kablam! | Jul 11 19:16:45.971 INFO kablam! 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Jul 11 19:16:45.971 INFO kablam! | ^^^^ Jul 11 19:16:45.974 INFO kablam! Jul 11 19:16:45.984 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 Jul 11 19:16:45.984 INFO kablam! --> src/tokio/mqtt_loop.rs:60:47 Jul 11 19:16:45.984 INFO kablam! | Jul 11 19:16:45.984 INFO kablam! 60 | Ok((next_state(sender), Ok(rx.boxed()))) Jul 11 19:16:45.985 INFO kablam! | ^^^^^ Jul 11 19:16:45.985 INFO kablam! Jul 11 19:16:46.006 INFO kablam! warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Jul 11 19:16:46.006 INFO kablam! --> src/tokio/mqtt_loop.rs:266:34 Jul 11 19:16:46.006 INFO kablam! | Jul 11 19:16:46.006 INFO kablam! 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Jul 11 19:16:46.006 INFO kablam! | ^^^^^^ Jul 11 19:16:46.006 INFO kablam! Jul 11 19:16:46.046 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 Jul 11 19:16:46.046 INFO kablam! --> src/tokio/mqtt_loop.rs:317:14 Jul 11 19:16:46.046 INFO kablam! | Jul 11 19:16:46.046 INFO kablam! 317 | .boxed() Jul 11 19:16:46.046 INFO kablam! | ^^^^^ Jul 11 19:16:46.046 INFO kablam! Jul 11 19:16:46.088 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 Jul 11 19:16:46.088 INFO kablam! --> src/tokio/mqtt_loop.rs:519:42 Jul 11 19:16:46.088 INFO kablam! | Jul 11 19:16:46.088 INFO kablam! 519 | .boxed(), Jul 11 19:16:46.088 INFO kablam! | ^^^^^ Jul 11 19:16:46.089 INFO kablam! Jul 11 19:16:46.130 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 Jul 11 19:16:46.130 INFO kablam! --> src/tokio/response.rs:83:40 Jul 11 19:16:46.130 INFO kablam! | Jul 11 19:16:46.130 INFO kablam! 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Jul 11 19:16:46.130 INFO kablam! | ^^^^^ Jul 11 19:16:46.130 INFO kablam! Jul 11 19:16:46.272 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 Jul 11 19:16:46.272 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Jul 11 19:16:46.272 INFO kablam! | Jul 11 19:16:46.272 INFO kablam! 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Jul 11 19:16:46.272 INFO kablam! | ^^^^^ Jul 11 19:16:46.272 INFO kablam! Jul 11 19:16:46.460 INFO kablam! warning: unused import: `Sink` Jul 11 19:16:46.460 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Jul 11 19:16:46.460 INFO kablam! | Jul 11 19:16:46.460 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.460 INFO kablam! | ^^^^ Jul 11 19:16:46.460 INFO kablam! Jul 11 19:16:46.460 INFO kablam! warning: unused import: `Sink` Jul 11 19:16:46.460 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Jul 11 19:16:46.460 INFO kablam! | Jul 11 19:16:46.460 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.460 INFO kablam! | ^^^^ Jul 11 19:16:46.461 INFO kablam! Jul 11 19:16:46.461 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.461 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Jul 11 19:16:46.461 INFO kablam! | Jul 11 19:16:46.461 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.461 INFO kablam! | ^^^^^^ Jul 11 19:16:46.461 INFO kablam! Jul 11 19:16:46.461 INFO kablam! warning: unused import: `Sink` Jul 11 19:16:46.461 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:39 Jul 11 19:16:46.461 INFO kablam! | Jul 11 19:16:46.461 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.461 INFO kablam! | ^^^^ Jul 11 19:16:46.461 INFO kablam! Jul 11 19:16:46.461 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.461 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:53 Jul 11 19:16:46.461 INFO kablam! | Jul 11 19:16:46.461 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.461 INFO kablam! | ^^^^^^ Jul 11 19:16:46.461 INFO kablam! Jul 11 19:16:46.461 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.461 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:53 Jul 11 19:16:46.461 INFO kablam! | Jul 11 19:16:46.461 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.462 INFO kablam! | ^^^^^^ Jul 11 19:16:46.462 INFO kablam! Jul 11 19:16:46.462 INFO kablam! warning: unused import: `Sink` Jul 11 19:16:46.462 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Jul 11 19:16:46.462 INFO kablam! | Jul 11 19:16:46.462 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.462 INFO kablam! | ^^^^ Jul 11 19:16:46.462 INFO kablam! Jul 11 19:16:46.462 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.462 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Jul 11 19:16:46.462 INFO kablam! | Jul 11 19:16:46.462 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.462 INFO kablam! | ^^^^^^ Jul 11 19:16:46.462 INFO kablam! Jul 11 19:16:46.462 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.462 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Jul 11 19:16:46.462 INFO kablam! | Jul 11 19:16:46.462 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.462 INFO kablam! | ^^^^^^ Jul 11 19:16:46.462 INFO kablam! Jul 11 19:16:46.462 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.462 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:53 Jul 11 19:16:46.462 INFO kablam! | Jul 11 19:16:46.463 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.463 INFO kablam! | ^^^^^^ Jul 11 19:16:46.463 INFO kablam! Jul 11 19:16:46.964 INFO kablam! warning: unused import: `Sink` Jul 11 19:16:46.964 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Jul 11 19:16:46.964 INFO kablam! | Jul 11 19:16:46.964 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.964 INFO kablam! | ^^^^ Jul 11 19:16:46.965 INFO kablam! Jul 11 19:16:46.965 INFO kablam! warning: unused import: `Sink` Jul 11 19:16:46.965 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Jul 11 19:16:46.965 INFO kablam! | Jul 11 19:16:46.965 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.965 INFO kablam! | ^^^^ Jul 11 19:16:46.965 INFO kablam! Jul 11 19:16:46.965 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.965 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Jul 11 19:16:46.965 INFO kablam! | Jul 11 19:16:46.965 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.965 INFO kablam! | ^^^^^^ Jul 11 19:16:46.965 INFO kablam! Jul 11 19:16:46.965 INFO kablam! warning: unused import: `Sink` Jul 11 19:16:46.965 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:39 Jul 11 19:16:46.965 INFO kablam! | Jul 11 19:16:46.965 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.965 INFO kablam! | ^^^^ Jul 11 19:16:46.965 INFO kablam! Jul 11 19:16:46.965 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.965 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:53 Jul 11 19:16:46.965 INFO kablam! | Jul 11 19:16:46.965 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.965 INFO kablam! | ^^^^^^ Jul 11 19:16:46.965 INFO kablam! Jul 11 19:16:46.965 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.965 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:53 Jul 11 19:16:46.966 INFO kablam! | Jul 11 19:16:46.966 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.966 INFO kablam! | ^^^^^^ Jul 11 19:16:46.966 INFO kablam! Jul 11 19:16:46.966 INFO kablam! warning: unused import: `Sink` Jul 11 19:16:46.966 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Jul 11 19:16:46.966 INFO kablam! | Jul 11 19:16:46.966 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.966 INFO kablam! | ^^^^ Jul 11 19:16:46.966 INFO kablam! Jul 11 19:16:46.966 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.966 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Jul 11 19:16:46.966 INFO kablam! | Jul 11 19:16:46.966 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.966 INFO kablam! | ^^^^^^ Jul 11 19:16:46.966 INFO kablam! Jul 11 19:16:46.966 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.966 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Jul 11 19:16:46.966 INFO kablam! | Jul 11 19:16:46.966 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.966 INFO kablam! | ^^^^^^ Jul 11 19:16:46.966 INFO kablam! Jul 11 19:16:46.966 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:46.966 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:53 Jul 11 19:16:46.966 INFO kablam! | Jul 11 19:16:46.966 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Jul 11 19:16:46.967 INFO kablam! | ^^^^^^ Jul 11 19:16:46.967 INFO kablam! Jul 11 19:16:47.876 INFO kablam! warning: variable does not need to be mutable Jul 11 19:16:47.876 INFO kablam! --> src/tokio/mqtt_loop.rs:320:31 Jul 11 19:16:47.876 INFO kablam! | Jul 11 19:16:47.876 INFO kablam! 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Jul 11 19:16:47.876 INFO kablam! | ----^^^ Jul 11 19:16:47.876 INFO kablam! | | Jul 11 19:16:47.876 INFO kablam! | help: remove this `mut` Jul 11 19:16:47.877 INFO kablam! | Jul 11 19:16:47.877 INFO kablam! = note: #[warn(unused_mut)] on by default Jul 11 19:16:47.877 INFO kablam! Jul 11 19:16:48.636 INFO kablam! warning: variable does not need to be mutable Jul 11 19:16:48.636 INFO kablam! --> src/tokio/mqtt_loop.rs:320:31 Jul 11 19:16:48.636 INFO kablam! | Jul 11 19:16:48.636 INFO kablam! 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Jul 11 19:16:48.636 INFO kablam! | ----^^^ Jul 11 19:16:48.637 INFO kablam! | | Jul 11 19:16:48.637 INFO kablam! | help: remove this `mut` Jul 11 19:16:48.637 INFO kablam! | Jul 11 19:16:48.637 INFO kablam! = note: #[warn(unused_mut)] on by default Jul 11 19:16:48.637 INFO kablam! Jul 11 19:16:48.871 INFO kablam! warning: unused `std::result::Result` which must be used Jul 11 19:16:48.871 INFO kablam! --> src/tokio/mqtt_loop.rs:571:17 Jul 11 19:16:48.871 INFO kablam! | Jul 11 19:16:48.871 INFO kablam! 571 | self.poll_queues(sourceitem); Jul 11 19:16:48.871 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:48.871 INFO kablam! | Jul 11 19:16:48.872 INFO kablam! = note: #[warn(unused_must_use)] on by default Jul 11 19:16:48.872 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Jul 11 19:16:48.872 INFO kablam! Jul 11 19:16:48.891 INFO kablam! warning: unused `std::result::Result` which must be used Jul 11 19:16:48.891 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:104:25 Jul 11 19:16:48.891 INFO kablam! | Jul 11 19:16:48.891 INFO kablam! 104 | / requester.unbounded_send(LoopRequest::Internal( Jul 11 19:16:48.891 INFO kablam! 105 | | MqttPacket::pub_ack_packet(*id), Jul 11 19:16:48.891 INFO kablam! 106 | | )); Jul 11 19:16:48.891 INFO kablam! | |___________________________^ Jul 11 19:16:48.891 INFO kablam! | Jul 11 19:16:48.891 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Jul 11 19:16:48.891 INFO kablam! Jul 11 19:16:48.892 INFO kablam! warning: unused `std::result::Result` which must be used Jul 11 19:16:48.892 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:128:29 Jul 11 19:16:48.892 INFO kablam! | Jul 11 19:16:48.892 INFO kablam! 128 | / requester.unbounded_send( Jul 11 19:16:48.892 INFO kablam! 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Jul 11 19:16:48.892 INFO kablam! 130 | | ); Jul 11 19:16:48.892 INFO kablam! | |______________________________^ Jul 11 19:16:48.892 INFO kablam! | Jul 11 19:16:48.892 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Jul 11 19:16:48.892 INFO kablam! Jul 11 19:16:48.897 INFO kablam! warning: unused `futures::sink::Send` which must be used Jul 11 19:16:48.897 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Jul 11 19:16:48.897 INFO kablam! | Jul 11 19:16:48.897 INFO kablam! 100 | requester.send(LoopRequest::Internal(rel)); Jul 11 19:16:48.897 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:48.897 INFO kablam! | Jul 11 19:16:48.897 INFO kablam! = note: futures do nothing unless polled Jul 11 19:16:48.897 INFO kablam! Jul 11 19:16:49.557 INFO kablam! warning: unused `std::result::Result` which must be used Jul 11 19:16:49.558 INFO kablam! --> src/tokio/mqtt_loop.rs:571:17 Jul 11 19:16:49.558 INFO kablam! | Jul 11 19:16:49.558 INFO kablam! 571 | self.poll_queues(sourceitem); Jul 11 19:16:49.558 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:49.558 INFO kablam! | Jul 11 19:16:49.558 INFO kablam! = note: #[warn(unused_must_use)] on by default Jul 11 19:16:49.558 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Jul 11 19:16:49.558 INFO kablam! Jul 11 19:16:49.575 INFO kablam! warning: unused `std::result::Result` which must be used Jul 11 19:16:49.576 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:104:25 Jul 11 19:16:49.576 INFO kablam! | Jul 11 19:16:49.576 INFO kablam! 104 | / requester.unbounded_send(LoopRequest::Internal( Jul 11 19:16:49.576 INFO kablam! 105 | | MqttPacket::pub_ack_packet(*id), Jul 11 19:16:49.576 INFO kablam! 106 | | )); Jul 11 19:16:49.576 INFO kablam! | |___________________________^ Jul 11 19:16:49.576 INFO kablam! | Jul 11 19:16:49.576 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Jul 11 19:16:49.576 INFO kablam! Jul 11 19:16:49.576 INFO kablam! warning: unused `std::result::Result` which must be used Jul 11 19:16:49.576 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:128:29 Jul 11 19:16:49.576 INFO kablam! | Jul 11 19:16:49.576 INFO kablam! 128 | / requester.unbounded_send( Jul 11 19:16:49.576 INFO kablam! 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Jul 11 19:16:49.576 INFO kablam! 130 | | ); Jul 11 19:16:49.576 INFO kablam! | |______________________________^ Jul 11 19:16:49.576 INFO kablam! | Jul 11 19:16:49.576 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Jul 11 19:16:49.576 INFO kablam! Jul 11 19:16:49.579 INFO kablam! warning: unused `futures::sink::Send` which must be used Jul 11 19:16:49.579 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Jul 11 19:16:49.579 INFO kablam! | Jul 11 19:16:49.579 INFO kablam! 100 | requester.send(LoopRequest::Internal(rel)); Jul 11 19:16:49.579 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:49.579 INFO kablam! | Jul 11 19:16:49.579 INFO kablam! = note: futures do nothing unless polled Jul 11 19:16:49.580 INFO kablam! Jul 11 19:16:51.326 INFO kablam! warning: unused `#[macro_use]` import Jul 11 19:16:51.326 INFO kablam! --> examples/client.rs:1:1 Jul 11 19:16:51.326 INFO kablam! | Jul 11 19:16:51.326 INFO kablam! 1 | #[macro_use] Jul 11 19:16:51.326 INFO kablam! | ^^^^^^^^^^^^ Jul 11 19:16:51.326 INFO kablam! | Jul 11 19:16:51.326 INFO kablam! = note: #[warn(unused_imports)] on by default Jul 11 19:16:51.326 INFO kablam! Jul 11 19:16:51.327 INFO kablam! warning: unused import: `tokio_mqttc::persistence::*` Jul 11 19:16:51.327 INFO kablam! --> examples/client.rs:11:5 Jul 11 19:16:51.327 INFO kablam! | Jul 11 19:16:51.327 INFO kablam! 11 | use tokio_mqttc::persistence::*; Jul 11 19:16:51.327 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:51.327 INFO kablam! Jul 11 19:16:51.327 INFO kablam! warning: unused import: `tokio_mqttc::proto::*` Jul 11 19:16:51.327 INFO kablam! --> examples/client.rs:13:5 Jul 11 19:16:51.327 INFO kablam! | Jul 11 19:16:51.327 INFO kablam! 13 | use tokio_mqttc::proto::*; Jul 11 19:16:51.327 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:51.328 INFO kablam! Jul 11 19:16:51.328 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:51.328 INFO kablam! --> examples/client.rs:17:5 Jul 11 19:16:51.328 INFO kablam! | Jul 11 19:16:51.328 INFO kablam! 17 | / error_chain! { Jul 11 19:16:51.328 INFO kablam! 18 | | types { Jul 11 19:16:51.328 INFO kablam! 19 | | Error, ErrorKind, ResultExt, Result; Jul 11 19:16:51.328 INFO kablam! 20 | | } Jul 11 19:16:51.328 INFO kablam! ... | Jul 11 19:16:51.328 INFO kablam! 35 | | } Jul 11 19:16:51.328 INFO kablam! 36 | | } Jul 11 19:16:51.328 INFO kablam! | |_____^ Jul 11 19:16:51.328 INFO kablam! | Jul 11 19:16:51.328 INFO kablam! = note: #[warn(renamed_and_removed_lints)] on by default Jul 11 19:16:51.328 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:51.328 INFO kablam! Jul 11 19:16:51.328 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:51.328 INFO kablam! --> examples/client.rs:17:5 Jul 11 19:16:51.328 INFO kablam! | Jul 11 19:16:51.328 INFO kablam! 17 | / error_chain! { Jul 11 19:16:51.328 INFO kablam! 18 | | types { Jul 11 19:16:51.328 INFO kablam! 19 | | Error, ErrorKind, ResultExt, Result; Jul 11 19:16:51.328 INFO kablam! 20 | | } Jul 11 19:16:51.328 INFO kablam! ... | Jul 11 19:16:51.328 INFO kablam! 35 | | } Jul 11 19:16:51.328 INFO kablam! 36 | | } Jul 11 19:16:51.329 INFO kablam! | |_____^ Jul 11 19:16:51.329 INFO kablam! | Jul 11 19:16:51.329 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:51.329 INFO kablam! Jul 11 19:16:51.329 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:51.329 INFO kablam! --> examples/client.rs:17:5 Jul 11 19:16:51.329 INFO kablam! | Jul 11 19:16:51.329 INFO kablam! 17 | / error_chain! { Jul 11 19:16:51.330 INFO kablam! 18 | | types { Jul 11 19:16:51.330 INFO kablam! 19 | | Error, ErrorKind, ResultExt, Result; Jul 11 19:16:51.330 INFO kablam! 20 | | } Jul 11 19:16:51.330 INFO kablam! ... | Jul 11 19:16:51.330 INFO kablam! 35 | | } Jul 11 19:16:51.330 INFO kablam! 36 | | } Jul 11 19:16:51.330 INFO kablam! | |_____^ Jul 11 19:16:51.330 INFO kablam! | Jul 11 19:16:51.330 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:51.330 INFO kablam! Jul 11 19:16:51.330 INFO kablam! warning: lint unused_doc_comment has been renamed to unused_doc_comments Jul 11 19:16:51.330 INFO kablam! --> examples/client.rs:17:5 Jul 11 19:16:51.330 INFO kablam! | Jul 11 19:16:51.330 INFO kablam! 17 | / error_chain! { Jul 11 19:16:51.330 INFO kablam! 18 | | types { Jul 11 19:16:51.330 INFO kablam! 19 | | Error, ErrorKind, ResultExt, Result; Jul 11 19:16:51.330 INFO kablam! 20 | | } Jul 11 19:16:51.330 INFO kablam! ... | Jul 11 19:16:51.330 INFO kablam! 35 | | } Jul 11 19:16:51.330 INFO kablam! 36 | | } Jul 11 19:16:51.330 INFO kablam! | |_____^ Jul 11 19:16:51.330 INFO kablam! | Jul 11 19:16:51.330 INFO kablam! = note: this error originates in a macro outside of the current crate (in Nightly builds, run with -Z external-macro-backtrace for more info) Jul 11 19:16:51.330 INFO kablam! Jul 11 19:16:51.330 INFO kablam! warning: unused import: `tokio_core::reactor::Handle` Jul 11 19:16:51.330 INFO kablam! --> examples/client.rs:41:5 Jul 11 19:16:51.331 INFO kablam! | Jul 11 19:16:51.331 INFO kablam! 41 | use tokio_core::reactor::Handle; Jul 11 19:16:51.331 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Jul 11 19:16:51.331 INFO kablam! Jul 11 19:16:51.331 INFO kablam! warning: unused imports: `Sink`, `future` Jul 11 19:16:51.331 INFO kablam! --> examples/client.rs:45:15 Jul 11 19:16:51.331 INFO kablam! | Jul 11 19:16:51.331 INFO kablam! 45 | use futures::{future, Future, Stream, Sink}; Jul 11 19:16:51.331 INFO kablam! | ^^^^^^ ^^^^ Jul 11 19:16:51.331 INFO kablam! Jul 11 19:16:51.623 INFO kablam! warning: unused import: `Stream` Jul 11 19:16:51.623 INFO kablam! --> examples/client.rs:45:31 Jul 11 19:16:51.623 INFO kablam! | Jul 11 19:16:51.623 INFO kablam! 45 | use futures::{future, Future, Stream, Sink}; Jul 11 19:16:51.623 INFO kablam! | ^^^^^^ Jul 11 19:16:51.624 INFO kablam! Jul 11 19:16:51.870 INFO kablam! Finished dev [unoptimized + debuginfo] target(s) in 18.99s Jul 11 19:16:51.891 INFO kablam! su: No module specific data is present Jul 11 19:16:52.510 INFO running `"docker" "rm" "-f" "39cc1353744cd4247e2a561d2f70bc61a0549f2f34b44965716d0d84e8843326"` Jul 11 19:16:52.693 INFO blam! 39cc1353744cd4247e2a561d2f70bc61a0549f2f34b44965716d0d84e8843326