Aug 10 23:46:22.805 INFO checking tokio-mqttc-0.0.2 against try#a77dfcc79fe3e7e1a10ae4dccfd4b2e5e0e49195+tmplazy for libc-1 Aug 10 23:46:22.805 INFO running: cargo +a77dfcc79fe3e7e1a10ae4dccfd4b2e5e0e49195-alt check --frozen --all --all-targets Aug 10 23:46:22.805 INFO creating container for: cargo +a77dfcc79fe3e7e1a10ae4dccfd4b2e5e0e49195-alt check --frozen --all --all-targets Aug 10 23:46:22.805 INFO running `"docker" "create" "-v" "/tmp/crater.Db4WFZKAzXGU:/source:ro,Z" "-v" "/home/ec2-user/crater/./work/local/target-dirs/libc-1/worker-7/try#a77dfcc79fe3e7e1a10ae4dccfd4b2e5e0e49195+tmplazy:/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" "-v" "/home/ec2-user/crater/./work/local/cargo-home/git:/cargo-home/git:rw,Z" "-e" "USER_ID=500" "-e" "CMD=cargo +a77dfcc79fe3e7e1a10ae4dccfd4b2e5e0e49195-alt check --frozen --all --all-targets" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "crater"` Aug 10 23:46:23.011 INFO blam! 1d45c60257063bd3fc87c8d0c6c0cb02e8b4edb239493b8ac57172bba2dcd19b Aug 10 23:46:23.013 INFO running `"docker" "start" "-a" "1d45c60257063bd3fc87c8d0c6c0cb02e8b4edb239493b8ac57172bba2dcd19b"` Aug 10 23:46:24.388 INFO kablam! Checking nom v2.2.1 Aug 10 23:46:24.390 INFO kablam! Checking futures-mutex v0.1.2 Aug 10 23:46:24.391 INFO kablam! Checking touch v0.0.1 Aug 10 23:46:24.394 INFO kablam! Checking serde_test v1.0.71 Aug 10 23:46:28.236 INFO kablam! Checking linked-hash-map v0.5.1 Aug 10 23:46:28.733 INFO kablam! Checking nom-test-helpers v2.0.0 Aug 10 23:46:29.104 INFO kablam! Checking tokio-mqttc v0.0.2 (file:///source) Aug 10 23:46:31.131 INFO kablam! warning: unused import: `Error` Aug 10 23:46:31.131 INFO kablam! --> src/proto/types.rs:4:14 Aug 10 23:46:31.131 INFO kablam! | Aug 10 23:46:31.131 INFO kablam! 4 | use errors::{Error, ErrorKind}; Aug 10 23:46:31.131 INFO kablam! | ^^^^^ Aug 10 23:46:31.131 INFO kablam! | Aug 10 23:46:31.131 INFO kablam! = note: #[warn(unused_imports)] on by default Aug 10 23:46:31.131 INFO kablam! Aug 10 23:46:31.131 INFO kablam! warning: unused import: `linked_hash_map::LinkedHashMap` Aug 10 23:46:31.131 INFO kablam! --> src/proto/types.rs:5:5 Aug 10 23:46:31.131 INFO kablam! | Aug 10 23:46:31.131 INFO kablam! 5 | use linked_hash_map::LinkedHashMap; Aug 10 23:46:31.131 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.131 INFO kablam! Aug 10 23:46:31.145 INFO kablam! warning: unused imports: `IResult`, `be_u16` Aug 10 23:46:31.145 INFO kablam! --> src/proto/headers.rs:3:11 Aug 10 23:46:31.145 INFO kablam! | Aug 10 23:46:31.145 INFO kablam! 3 | use nom::{IResult, be_u16}; Aug 10 23:46:31.145 INFO kablam! | ^^^^^^^ ^^^^^^ Aug 10 23:46:31.145 INFO kablam! Aug 10 23:46:31.145 INFO kablam! warning: unused import: `std::io` Aug 10 23:46:31.145 INFO kablam! --> src/proto/mod.rs:8:5 Aug 10 23:46:31.145 INFO kablam! | Aug 10 23:46:31.145 INFO kablam! 8 | use std::io; Aug 10 23:46:31.145 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.145 INFO kablam! Aug 10 23:46:31.145 INFO kablam! warning: unused import: `Entry` Aug 10 23:46:31.145 INFO kablam! --> src/proto/mod.rs:12:23 Aug 10 23:46:31.146 INFO kablam! | Aug 10 23:46:31.146 INFO kablam! 12 | use linked_hash_map::{Entry,LinkedHashMap}; Aug 10 23:46:31.146 INFO kablam! | ^^^^^ Aug 10 23:46:31.146 INFO kablam! Aug 10 23:46:31.146 INFO kablam! warning: unused import: `Writer` Aug 10 23:46:31.146 INFO kablam! --> src/proto/mod.rs:13:38 Aug 10 23:46:31.146 INFO kablam! | Aug 10 23:46:31.146 INFO kablam! 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Aug 10 23:46:31.146 INFO kablam! | ^^^^^^ Aug 10 23:46:31.146 INFO kablam! Aug 10 23:46:31.146 INFO kablam! warning: unused import: `self::headers::*` Aug 10 23:46:31.146 INFO kablam! --> src/proto/mod.rs:15:5 Aug 10 23:46:31.146 INFO kablam! | Aug 10 23:46:31.146 INFO kablam! 15 | use self::headers::*; Aug 10 23:46:31.147 INFO kablam! | ^^^^^^^^^^^^^^^^ Aug 10 23:46:31.147 INFO kablam! Aug 10 23:46:31.150 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.150 INFO kablam! --> src/tokio/mqtt_loop.rs:13:5 Aug 10 23:46:31.150 INFO kablam! | Aug 10 23:46:31.150 INFO kablam! 13 | use take::Take; Aug 10 23:46:31.150 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.150 INFO kablam! Aug 10 23:46:31.150 INFO kablam! warning: unused import: `MqttFramedWriter` Aug 10 23:46:31.150 INFO kablam! --> src/tokio/mqtt_loop.rs:21:13 Aug 10 23:46:31.150 INFO kablam! | Aug 10 23:46:31.150 INFO kablam! 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Aug 10 23:46:31.150 INFO kablam! | ^^^^^^^^^^^^^^^^ Aug 10 23:46:31.150 INFO kablam! Aug 10 23:46:31.150 INFO kablam! warning: unused import: `super::response::ResponseProcessor` Aug 10 23:46:31.150 INFO kablam! --> src/tokio/mqtt_loop.rs:23:5 Aug 10 23:46:31.150 INFO kablam! | Aug 10 23:46:31.150 INFO kablam! 23 | use super::response::ResponseProcessor; Aug 10 23:46:31.150 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.150 INFO kablam! Aug 10 23:46:31.150 INFO kablam! warning: unused import: `super::request::RequestProcessor` Aug 10 23:46:31.150 INFO kablam! --> src/tokio/mqtt_loop.rs:24:5 Aug 10 23:46:31.150 INFO kablam! | Aug 10 23:46:31.151 INFO kablam! 24 | use super::request::RequestProcessor; Aug 10 23:46:31.151 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.151 INFO kablam! Aug 10 23:46:31.156 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.156 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:1:16 Aug 10 23:46:31.156 INFO kablam! | Aug 10 23:46:31.156 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.156 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.156 INFO kablam! Aug 10 23:46:31.156 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Aug 10 23:46:31.156 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:2:28 Aug 10 23:46:31.156 INFO kablam! | Aug 10 23:46:31.156 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Aug 10 23:46:31.156 INFO kablam! | ^^^^^^^^^ ^^^^ Aug 10 23:46:31.156 INFO kablam! Aug 10 23:46:31.156 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.156 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:4:5 Aug 10 23:46:31.156 INFO kablam! | Aug 10 23:46:31.156 INFO kablam! 4 | use take::Take; Aug 10 23:46:31.156 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.156 INFO kablam! Aug 10 23:46:31.156 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.156 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:6:5 Aug 10 23:46:31.156 INFO kablam! | Aug 10 23:46:31.156 INFO kablam! 6 | use bincode; Aug 10 23:46:31.156 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.156 INFO kablam! Aug 10 23:46:31.156 INFO kablam! warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Aug 10 23:46:31.157 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:9:25 Aug 10 23:46:31.157 INFO kablam! | Aug 10 23:46:31.157 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Aug 10 23:46:31.157 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Aug 10 23:46:31.157 INFO kablam! Aug 10 23:46:31.157 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt` Aug 10 23:46:31.157 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:10:29 Aug 10 23:46:31.157 INFO kablam! | Aug 10 23:46:31.157 INFO kablam! 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.157 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.157 INFO kablam! Aug 10 23:46:31.157 INFO kablam! warning: unused import: `PublishState` Aug 10 23:46:31.157 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:12:25 Aug 10 23:46:31.157 INFO kablam! | Aug 10 23:46:31.157 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Aug 10 23:46:31.157 INFO kablam! | ^^^^^^^^^^^^ Aug 10 23:46:31.157 INFO kablam! Aug 10 23:46:31.157 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.157 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:1:16 Aug 10 23:46:31.157 INFO kablam! | Aug 10 23:46:31.157 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.157 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.157 INFO kablam! Aug 10 23:46:31.157 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Aug 10 23:46:31.157 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:2:28 Aug 10 23:46:31.157 INFO kablam! | Aug 10 23:46:31.157 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Aug 10 23:46:31.157 INFO kablam! | ^^^^^^^^^ ^^^^ Aug 10 23:46:31.157 INFO kablam! Aug 10 23:46:31.157 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.158 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:4:5 Aug 10 23:46:31.158 INFO kablam! | Aug 10 23:46:31.158 INFO kablam! 4 | use take::Take; Aug 10 23:46:31.158 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.158 INFO kablam! Aug 10 23:46:31.158 INFO kablam! warning: unused import: `PacketType` Aug 10 23:46:31.158 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:9:25 Aug 10 23:46:31.158 INFO kablam! | Aug 10 23:46:31.158 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Aug 10 23:46:31.158 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.158 INFO kablam! Aug 10 23:46:31.158 INFO kablam! warning: unused import: `OneTimeKey` Aug 10 23:46:31.158 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:12:13 Aug 10 23:46:31.158 INFO kablam! | Aug 10 23:46:31.158 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Aug 10 23:46:31.158 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.158 INFO kablam! Aug 10 23:46:31.158 INFO kablam! warning: unused import: `BoxFuture` Aug 10 23:46:31.158 INFO kablam! --> src/tokio/outbound_handlers/mod.rs:8:27 Aug 10 23:46:31.158 INFO kablam! | Aug 10 23:46:31.158 INFO kablam! 8 | use tokio::{RequestTuple, BoxFuture}; Aug 10 23:46:31.158 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.158 INFO kablam! Aug 10 23:46:31.158 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.158 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Aug 10 23:46:31.158 INFO kablam! | Aug 10 23:46:31.158 INFO kablam! 3 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.158 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.158 INFO kablam! Aug 10 23:46:31.158 INFO kablam! warning: unused import: `AsyncSink` Aug 10 23:46:31.158 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Aug 10 23:46:31.158 INFO kablam! | Aug 10 23:46:31.158 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.158 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.158 INFO kablam! Aug 10 23:46:31.158 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Aug 10 23:46:31.159 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Aug 10 23:46:31.159 INFO kablam! | Aug 10 23:46:31.159 INFO kablam! 6 | use futures::unsync::mpsc::UnboundedSender; Aug 10 23:46:31.159 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.159 INFO kablam! Aug 10 23:46:31.159 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.159 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Aug 10 23:46:31.159 INFO kablam! | Aug 10 23:46:31.159 INFO kablam! 7 | use take::Take; Aug 10 23:46:31.159 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.159 INFO kablam! Aug 10 23:46:31.159 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.159 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Aug 10 23:46:31.159 INFO kablam! | Aug 10 23:46:31.159 INFO kablam! 9 | use bincode; Aug 10 23:46:31.159 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.159 INFO kablam! Aug 10 23:46:31.159 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Aug 10 23:46:31.159 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Aug 10 23:46:31.159 INFO kablam! | Aug 10 23:46:31.159 INFO kablam! 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.159 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.159 INFO kablam! 12 | PacketId, TopicName}; Aug 10 23:46:31.159 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.159 INFO kablam! Aug 10 23:46:31.159 INFO kablam! warning: unused imports: `ResultExt`, `Result` Aug 10 23:46:31.159 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Aug 10 23:46:31.159 INFO kablam! | Aug 10 23:46:31.159 INFO kablam! 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.159 INFO kablam! | ^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.159 INFO kablam! Aug 10 23:46:31.160 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Aug 10 23:46:31.160 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Aug 10 23:46:31.160 INFO kablam! | Aug 10 23:46:31.160 INFO kablam! 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Aug 10 23:46:31.160 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.160 INFO kablam! Aug 10 23:46:31.160 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.160 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Aug 10 23:46:31.160 INFO kablam! | Aug 10 23:46:31.160 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.160 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.160 INFO kablam! Aug 10 23:46:31.162 INFO kablam! warning: unused import: `AsyncSink` Aug 10 23:46:31.163 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Aug 10 23:46:31.163 INFO kablam! | Aug 10 23:46:31.163 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.163 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.163 INFO kablam! Aug 10 23:46:31.163 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.163 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Aug 10 23:46:31.163 INFO kablam! | Aug 10 23:46:31.163 INFO kablam! 6 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.163 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.163 INFO kablam! Aug 10 23:46:31.163 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Aug 10 23:46:31.163 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Aug 10 23:46:31.163 INFO kablam! | Aug 10 23:46:31.163 INFO kablam! 7 | use futures::unsync::mpsc::UnboundedSender; Aug 10 23:46:31.163 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.163 INFO kablam! Aug 10 23:46:31.163 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.163 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Aug 10 23:46:31.163 INFO kablam! | Aug 10 23:46:31.164 INFO kablam! 8 | use take::Take; Aug 10 23:46:31.164 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.164 INFO kablam! Aug 10 23:46:31.164 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.164 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Aug 10 23:46:31.164 INFO kablam! | Aug 10 23:46:31.164 INFO kablam! 10 | use bincode; Aug 10 23:46:31.164 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.164 INFO kablam! Aug 10 23:46:31.164 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Aug 10 23:46:31.164 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Aug 10 23:46:31.164 INFO kablam! | Aug 10 23:46:31.164 INFO kablam! 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.164 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.164 INFO kablam! 13 | PacketId, TopicName}; Aug 10 23:46:31.164 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.164 INFO kablam! Aug 10 23:46:31.164 INFO kablam! warning: unused imports: `ResultExt`, `Result` Aug 10 23:46:31.164 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Aug 10 23:46:31.164 INFO kablam! | Aug 10 23:46:31.164 INFO kablam! 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.165 INFO kablam! | ^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.165 INFO kablam! Aug 10 23:46:31.165 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.165 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Aug 10 23:46:31.165 INFO kablam! | Aug 10 23:46:31.165 INFO kablam! 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Aug 10 23:46:31.165 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.165 INFO kablam! Aug 10 23:46:31.165 INFO kablam! warning: unused import: `std::ops::Deref` Aug 10 23:46:31.165 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:2:5 Aug 10 23:46:31.165 INFO kablam! | Aug 10 23:46:31.165 INFO kablam! 2 | use std::ops::Deref; Aug 10 23:46:31.165 INFO kablam! | ^^^^^^^^^^^^^^^ Aug 10 23:46:31.165 INFO kablam! Aug 10 23:46:31.165 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.165 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:4:16 Aug 10 23:46:31.165 INFO kablam! | Aug 10 23:46:31.165 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.165 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.165 INFO kablam! Aug 10 23:46:31.165 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Aug 10 23:46:31.166 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:15 Aug 10 23:46:31.166 INFO kablam! | Aug 10 23:46:31.166 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.166 INFO kablam! | ^^^^ ^^^^^^^^^ Aug 10 23:46:31.166 INFO kablam! Aug 10 23:46:31.166 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.166 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:7:5 Aug 10 23:46:31.166 INFO kablam! | Aug 10 23:46:31.166 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.166 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.166 INFO kablam! Aug 10 23:46:31.166 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Aug 10 23:46:31.166 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:8:5 Aug 10 23:46:31.166 INFO kablam! | Aug 10 23:46:31.166 INFO kablam! 8 | use futures::unsync::mpsc::UnboundedSender; Aug 10 23:46:31.166 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.166 INFO kablam! Aug 10 23:46:31.166 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.166 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:9:5 Aug 10 23:46:31.166 INFO kablam! | Aug 10 23:46:31.166 INFO kablam! 9 | use take::Take; Aug 10 23:46:31.166 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.166 INFO kablam! Aug 10 23:46:31.167 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.167 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:11:5 Aug 10 23:46:31.167 INFO kablam! | Aug 10 23:46:31.167 INFO kablam! 11 | use bincode; Aug 10 23:46:31.167 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.167 INFO kablam! Aug 10 23:46:31.167 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Aug 10 23:46:31.167 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:13:13 Aug 10 23:46:31.167 INFO kablam! | Aug 10 23:46:31.167 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.167 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.167 INFO kablam! 14 | PacketId, TopicName}; Aug 10 23:46:31.167 INFO kablam! | ^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.167 INFO kablam! Aug 10 23:46:31.167 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Aug 10 23:46:31.167 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:16:21 Aug 10 23:46:31.167 INFO kablam! | Aug 10 23:46:31.167 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.167 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.167 INFO kablam! Aug 10 23:46:31.167 INFO kablam! warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Aug 10 23:46:31.168 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:17:5 Aug 10 23:46:31.168 INFO kablam! | Aug 10 23:46:31.168 INFO kablam! 17 | use errors::proto::ErrorKind as ProtoErrorKind; Aug 10 23:46:31.168 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.168 INFO kablam! Aug 10 23:46:31.168 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.168 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:19:25 Aug 10 23:46:31.168 INFO kablam! | Aug 10 23:46:31.168 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Aug 10 23:46:31.168 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.168 INFO kablam! Aug 10 23:46:31.168 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Aug 10 23:46:31.168 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:1:5 Aug 10 23:46:31.168 INFO kablam! | Aug 10 23:46:31.168 INFO kablam! 1 | use std::collections::hash_map::Entry; Aug 10 23:46:31.168 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.168 INFO kablam! Aug 10 23:46:31.168 INFO kablam! warning: unused import: `std::ops::Deref` Aug 10 23:46:31.168 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:2:5 Aug 10 23:46:31.168 INFO kablam! | Aug 10 23:46:31.168 INFO kablam! 2 | use std::ops::Deref; Aug 10 23:46:31.168 INFO kablam! | ^^^^^^^^^^^^^^^ Aug 10 23:46:31.168 INFO kablam! Aug 10 23:46:31.169 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.169 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:5:16 Aug 10 23:46:31.169 INFO kablam! | Aug 10 23:46:31.169 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.169 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.169 INFO kablam! Aug 10 23:46:31.169 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Aug 10 23:46:31.169 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:28 Aug 10 23:46:31.169 INFO kablam! | Aug 10 23:46:31.169 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.169 INFO kablam! | ^^^^^^^^^ ^^^^ Aug 10 23:46:31.169 INFO kablam! Aug 10 23:46:31.169 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.169 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:7:5 Aug 10 23:46:31.169 INFO kablam! | Aug 10 23:46:31.169 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.169 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.169 INFO kablam! Aug 10 23:46:31.169 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.169 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:9:5 Aug 10 23:46:31.169 INFO kablam! | Aug 10 23:46:31.169 INFO kablam! 9 | use take::Take; Aug 10 23:46:31.170 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.170 INFO kablam! Aug 10 23:46:31.170 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.170 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:11:5 Aug 10 23:46:31.170 INFO kablam! | Aug 10 23:46:31.170 INFO kablam! 11 | use bincode; Aug 10 23:46:31.170 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.170 INFO kablam! Aug 10 23:46:31.170 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Aug 10 23:46:31.170 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:13:25 Aug 10 23:46:31.170 INFO kablam! | Aug 10 23:46:31.170 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.170 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.170 INFO kablam! Aug 10 23:46:31.170 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Aug 10 23:46:31.170 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:16:21 Aug 10 23:46:31.170 INFO kablam! | Aug 10 23:46:31.170 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.170 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.170 INFO kablam! Aug 10 23:46:31.170 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.170 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:19:13 Aug 10 23:46:31.171 INFO kablam! | Aug 10 23:46:31.171 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Aug 10 23:46:31.171 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.171 INFO kablam! Aug 10 23:46:31.171 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Aug 10 23:46:31.171 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Aug 10 23:46:31.171 INFO kablam! | Aug 10 23:46:31.171 INFO kablam! 1 | use std::collections::hash_map::Entry; Aug 10 23:46:31.171 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.171 INFO kablam! Aug 10 23:46:31.171 INFO kablam! warning: unused import: `std::ops::Deref` Aug 10 23:46:31.171 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Aug 10 23:46:31.171 INFO kablam! | Aug 10 23:46:31.171 INFO kablam! 2 | use std::ops::Deref; Aug 10 23:46:31.171 INFO kablam! | ^^^^^^^^^^^^^^^ Aug 10 23:46:31.171 INFO kablam! Aug 10 23:46:31.171 INFO kablam! warning: unused import: `bytes::Bytes` Aug 10 23:46:31.171 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Aug 10 23:46:31.171 INFO kablam! | Aug 10 23:46:31.171 INFO kablam! 4 | use bytes::Bytes; Aug 10 23:46:31.171 INFO kablam! | ^^^^^^^^^^^^ Aug 10 23:46:31.171 INFO kablam! Aug 10 23:46:31.171 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.173 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Aug 10 23:46:31.173 INFO kablam! | Aug 10 23:46:31.173 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.173 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.173 INFO kablam! Aug 10 23:46:31.173 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Aug 10 23:46:31.173 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Aug 10 23:46:31.173 INFO kablam! | Aug 10 23:46:31.173 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.173 INFO kablam! | ^^^^ ^^^^^^^^^ Aug 10 23:46:31.173 INFO kablam! Aug 10 23:46:31.173 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.173 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Aug 10 23:46:31.173 INFO kablam! | Aug 10 23:46:31.173 INFO kablam! 8 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.173 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.173 INFO kablam! Aug 10 23:46:31.173 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Aug 10 23:46:31.173 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Aug 10 23:46:31.173 INFO kablam! | Aug 10 23:46:31.173 INFO kablam! 9 | use futures::unsync::mpsc::UnboundedSender; Aug 10 23:46:31.173 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.173 INFO kablam! Aug 10 23:46:31.173 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.173 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Aug 10 23:46:31.174 INFO kablam! | Aug 10 23:46:31.174 INFO kablam! 10 | use take::Take; Aug 10 23:46:31.174 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.174 INFO kablam! Aug 10 23:46:31.174 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.174 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Aug 10 23:46:31.174 INFO kablam! | Aug 10 23:46:31.174 INFO kablam! 12 | use bincode; Aug 10 23:46:31.174 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.174 INFO kablam! Aug 10 23:46:31.174 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Aug 10 23:46:31.174 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Aug 10 23:46:31.174 INFO kablam! | Aug 10 23:46:31.174 INFO kablam! 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.174 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.174 INFO kablam! 15 | PacketId, TopicName}; Aug 10 23:46:31.174 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.174 INFO kablam! Aug 10 23:46:31.174 INFO kablam! warning: unused import: `Result` Aug 10 23:46:31.174 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Aug 10 23:46:31.174 INFO kablam! | Aug 10 23:46:31.174 INFO kablam! 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.174 INFO kablam! | ^^^^^^ Aug 10 23:46:31.174 INFO kablam! Aug 10 23:46:31.174 INFO kablam! warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.174 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Aug 10 23:46:31.174 INFO kablam! | Aug 10 23:46:31.175 INFO kablam! 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Aug 10 23:46:31.175 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.175 INFO kablam! Aug 10 23:46:31.175 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Aug 10 23:46:31.176 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Aug 10 23:46:31.176 INFO kablam! | Aug 10 23:46:31.176 INFO kablam! 1 | use std::collections::hash_map::Entry; Aug 10 23:46:31.176 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.176 INFO kablam! Aug 10 23:46:31.176 INFO kablam! warning: unused import: `std::ops::Deref` Aug 10 23:46:31.176 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Aug 10 23:46:31.176 INFO kablam! | Aug 10 23:46:31.176 INFO kablam! 2 | use std::ops::Deref; Aug 10 23:46:31.176 INFO kablam! | ^^^^^^^^^^^^^^^ Aug 10 23:46:31.176 INFO kablam! Aug 10 23:46:31.176 INFO kablam! warning: unused import: `bytes::Bytes` Aug 10 23:46:31.176 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Aug 10 23:46:31.176 INFO kablam! | Aug 10 23:46:31.176 INFO kablam! 4 | use bytes::Bytes; Aug 10 23:46:31.176 INFO kablam! | ^^^^^^^^^^^^ Aug 10 23:46:31.176 INFO kablam! Aug 10 23:46:31.176 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.176 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Aug 10 23:46:31.176 INFO kablam! | Aug 10 23:46:31.176 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.176 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.176 INFO kablam! Aug 10 23:46:31.177 INFO kablam! warning: unused import: `AsyncSink` Aug 10 23:46:31.177 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Aug 10 23:46:31.177 INFO kablam! | Aug 10 23:46:31.177 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.177 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.177 INFO kablam! Aug 10 23:46:31.177 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.177 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Aug 10 23:46:31.177 INFO kablam! | Aug 10 23:46:31.177 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.177 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.177 INFO kablam! Aug 10 23:46:31.177 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.177 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Aug 10 23:46:31.177 INFO kablam! | Aug 10 23:46:31.177 INFO kablam! 9 | use take::Take; Aug 10 23:46:31.177 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.177 INFO kablam! Aug 10 23:46:31.177 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Aug 10 23:46:31.177 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Aug 10 23:46:31.177 INFO kablam! | Aug 10 23:46:31.177 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.177 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.177 INFO kablam! 14 | PacketId, TopicName}; Aug 10 23:46:31.177 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.177 INFO kablam! Aug 10 23:46:31.177 INFO kablam! warning: unused import: `Result` Aug 10 23:46:31.177 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Aug 10 23:46:31.177 INFO kablam! | Aug 10 23:46:31.177 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.177 INFO kablam! | ^^^^^^ Aug 10 23:46:31.177 INFO kablam! Aug 10 23:46:31.177 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.178 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Aug 10 23:46:31.178 INFO kablam! | Aug 10 23:46:31.178 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Aug 10 23:46:31.178 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.178 INFO kablam! Aug 10 23:46:31.178 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Aug 10 23:46:31.178 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:1:5 Aug 10 23:46:31.178 INFO kablam! | Aug 10 23:46:31.178 INFO kablam! 1 | use std::collections::hash_map::Entry; Aug 10 23:46:31.178 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.178 INFO kablam! Aug 10 23:46:31.178 INFO kablam! warning: unused import: `std::ops::Deref` Aug 10 23:46:31.178 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:2:5 Aug 10 23:46:31.178 INFO kablam! | Aug 10 23:46:31.178 INFO kablam! 2 | use std::ops::Deref; Aug 10 23:46:31.178 INFO kablam! | ^^^^^^^^^^^^^^^ Aug 10 23:46:31.178 INFO kablam! Aug 10 23:46:31.178 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.178 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:5:16 Aug 10 23:46:31.178 INFO kablam! | Aug 10 23:46:31.178 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.178 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.178 INFO kablam! Aug 10 23:46:31.178 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Aug 10 23:46:31.178 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:28 Aug 10 23:46:31.178 INFO kablam! | Aug 10 23:46:31.178 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.178 INFO kablam! | ^^^^^^^^^ ^^^^ Aug 10 23:46:31.178 INFO kablam! Aug 10 23:46:31.178 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.178 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:7:5 Aug 10 23:46:31.178 INFO kablam! | Aug 10 23:46:31.178 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.178 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.178 INFO kablam! Aug 10 23:46:31.178 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.178 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:9:5 Aug 10 23:46:31.179 INFO kablam! | Aug 10 23:46:31.179 INFO kablam! 9 | use take::Take; Aug 10 23:46:31.179 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.179 INFO kablam! Aug 10 23:46:31.179 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.179 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:11:5 Aug 10 23:46:31.179 INFO kablam! | Aug 10 23:46:31.179 INFO kablam! 11 | use bincode; Aug 10 23:46:31.179 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.179 INFO kablam! Aug 10 23:46:31.179 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Aug 10 23:46:31.179 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:13:25 Aug 10 23:46:31.179 INFO kablam! | Aug 10 23:46:31.179 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.179 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.179 INFO kablam! Aug 10 23:46:31.179 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Aug 10 23:46:31.179 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:16:21 Aug 10 23:46:31.179 INFO kablam! | Aug 10 23:46:31.179 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.179 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.179 INFO kablam! Aug 10 23:46:31.179 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.179 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:19:13 Aug 10 23:46:31.179 INFO kablam! | Aug 10 23:46:31.179 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Aug 10 23:46:31.179 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.179 INFO kablam! Aug 10 23:46:31.247 INFO kablam! warning: unused import: `Error` Aug 10 23:46:31.247 INFO kablam! --> src/proto/types.rs:4:14 Aug 10 23:46:31.247 INFO kablam! | Aug 10 23:46:31.247 INFO kablam! 4 | use errors::{Error, ErrorKind}; Aug 10 23:46:31.247 INFO kablam! | ^^^^^ Aug 10 23:46:31.247 INFO kablam! | Aug 10 23:46:31.247 INFO kablam! = note: #[warn(unused_imports)] on by default Aug 10 23:46:31.247 INFO kablam! Aug 10 23:46:31.247 INFO kablam! warning: unused import: `linked_hash_map::LinkedHashMap` Aug 10 23:46:31.247 INFO kablam! --> src/proto/types.rs:5:5 Aug 10 23:46:31.247 INFO kablam! | Aug 10 23:46:31.247 INFO kablam! 5 | use linked_hash_map::LinkedHashMap; Aug 10 23:46:31.247 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.248 INFO kablam! Aug 10 23:46:31.260 INFO kablam! warning: unused imports: `IResult`, `be_u16` Aug 10 23:46:31.260 INFO kablam! --> src/proto/headers.rs:3:11 Aug 10 23:46:31.260 INFO kablam! | Aug 10 23:46:31.260 INFO kablam! 3 | use nom::{IResult, be_u16}; Aug 10 23:46:31.260 INFO kablam! | ^^^^^^^ ^^^^^^ Aug 10 23:46:31.260 INFO kablam! Aug 10 23:46:31.260 INFO kablam! warning: unused import: `std::io` Aug 10 23:46:31.260 INFO kablam! --> src/proto/mod.rs:8:5 Aug 10 23:46:31.260 INFO kablam! | Aug 10 23:46:31.260 INFO kablam! 8 | use std::io; Aug 10 23:46:31.260 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.260 INFO kablam! Aug 10 23:46:31.261 INFO kablam! warning: unused import: `Entry` Aug 10 23:46:31.261 INFO kablam! --> src/proto/mod.rs:12:23 Aug 10 23:46:31.261 INFO kablam! | Aug 10 23:46:31.261 INFO kablam! 12 | use linked_hash_map::{Entry,LinkedHashMap}; Aug 10 23:46:31.261 INFO kablam! | ^^^^^ Aug 10 23:46:31.261 INFO kablam! Aug 10 23:46:31.261 INFO kablam! warning: unused import: `Writer` Aug 10 23:46:31.261 INFO kablam! --> src/proto/mod.rs:13:38 Aug 10 23:46:31.261 INFO kablam! | Aug 10 23:46:31.261 INFO kablam! 13 | use bytes::{Bytes, BytesMut, BufMut, Writer}; Aug 10 23:46:31.261 INFO kablam! | ^^^^^^ Aug 10 23:46:31.261 INFO kablam! Aug 10 23:46:31.261 INFO kablam! warning: unused import: `self::headers::*` Aug 10 23:46:31.261 INFO kablam! --> src/proto/mod.rs:15:5 Aug 10 23:46:31.261 INFO kablam! | Aug 10 23:46:31.261 INFO kablam! 15 | use self::headers::*; Aug 10 23:46:31.261 INFO kablam! | ^^^^^^^^^^^^^^^^ Aug 10 23:46:31.261 INFO kablam! Aug 10 23:46:31.263 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.265 INFO kablam! --> src/tokio/mqtt_loop.rs:13:5 Aug 10 23:46:31.265 INFO kablam! | Aug 10 23:46:31.265 INFO kablam! 13 | use take::Take; Aug 10 23:46:31.265 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.265 INFO kablam! Aug 10 23:46:31.265 INFO kablam! warning: unused import: `MqttFramedWriter` Aug 10 23:46:31.265 INFO kablam! --> src/tokio/mqtt_loop.rs:21:13 Aug 10 23:46:31.265 INFO kablam! | Aug 10 23:46:31.265 INFO kablam! 21 | MqttFramedWriter, MqttFramedReader, SubscriptionSender, SourceItem, SourceError, Aug 10 23:46:31.265 INFO kablam! | ^^^^^^^^^^^^^^^^ Aug 10 23:46:31.265 INFO kablam! Aug 10 23:46:31.265 INFO kablam! warning: unused import: `super::response::ResponseProcessor` Aug 10 23:46:31.265 INFO kablam! --> src/tokio/mqtt_loop.rs:23:5 Aug 10 23:46:31.265 INFO kablam! | Aug 10 23:46:31.265 INFO kablam! 23 | use super::response::ResponseProcessor; Aug 10 23:46:31.265 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.265 INFO kablam! Aug 10 23:46:31.265 INFO kablam! warning: unused import: `super::request::RequestProcessor` Aug 10 23:46:31.265 INFO kablam! --> src/tokio/mqtt_loop.rs:24:5 Aug 10 23:46:31.265 INFO kablam! | Aug 10 23:46:31.265 INFO kablam! 24 | use super::request::RequestProcessor; Aug 10 23:46:31.266 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.266 INFO kablam! Aug 10 23:46:31.266 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.266 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:1:16 Aug 10 23:46:31.267 INFO kablam! | Aug 10 23:46:31.267 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.267 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.267 INFO kablam! Aug 10 23:46:31.267 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Aug 10 23:46:31.267 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:2:28 Aug 10 23:46:31.267 INFO kablam! | Aug 10 23:46:31.267 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Aug 10 23:46:31.267 INFO kablam! | ^^^^^^^^^ ^^^^ Aug 10 23:46:31.267 INFO kablam! Aug 10 23:46:31.267 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.267 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:4:5 Aug 10 23:46:31.267 INFO kablam! | Aug 10 23:46:31.267 INFO kablam! 4 | use take::Take; Aug 10 23:46:31.267 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.267 INFO kablam! Aug 10 23:46:31.267 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.267 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:6:5 Aug 10 23:46:31.267 INFO kablam! | Aug 10 23:46:31.267 INFO kablam! 6 | use bincode; Aug 10 23:46:31.267 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.267 INFO kablam! Aug 10 23:46:31.267 INFO kablam! warning: unused imports: `PacketId`, `PacketType`, `QualityOfService` Aug 10 23:46:31.267 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:9:25 Aug 10 23:46:31.267 INFO kablam! | Aug 10 23:46:31.267 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Aug 10 23:46:31.267 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^ Aug 10 23:46:31.267 INFO kablam! Aug 10 23:46:31.267 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt` Aug 10 23:46:31.268 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:10:29 Aug 10 23:46:31.268 INFO kablam! | Aug 10 23:46:31.268 INFO kablam! 10 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.268 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.268 INFO kablam! Aug 10 23:46:31.268 INFO kablam! warning: unused import: `PublishState` Aug 10 23:46:31.268 INFO kablam! --> src/tokio/outbound_handlers/ping_request.rs:12:25 Aug 10 23:46:31.268 INFO kablam! | Aug 10 23:46:31.268 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Aug 10 23:46:31.268 INFO kablam! | ^^^^^^^^^^^^ Aug 10 23:46:31.268 INFO kablam! Aug 10 23:46:31.268 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.268 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:1:16 Aug 10 23:46:31.268 INFO kablam! | Aug 10 23:46:31.268 INFO kablam! 1 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.268 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.268 INFO kablam! Aug 10 23:46:31.268 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Aug 10 23:46:31.268 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:2:28 Aug 10 23:46:31.268 INFO kablam! | Aug 10 23:46:31.268 INFO kablam! 2 | use futures::{Poll, Async, AsyncSink, Sink, Future}; Aug 10 23:46:31.268 INFO kablam! | ^^^^^^^^^ ^^^^ Aug 10 23:46:31.268 INFO kablam! Aug 10 23:46:31.268 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.268 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:4:5 Aug 10 23:46:31.268 INFO kablam! | Aug 10 23:46:31.268 INFO kablam! 4 | use take::Take; Aug 10 23:46:31.268 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.268 INFO kablam! Aug 10 23:46:31.268 INFO kablam! warning: unused import: `PacketType` Aug 10 23:46:31.269 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:9:25 Aug 10 23:46:31.269 INFO kablam! | Aug 10 23:46:31.269 INFO kablam! 9 | use proto::{MqttPacket, PacketType, QualityOfService, PacketId}; Aug 10 23:46:31.269 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.269 INFO kablam! Aug 10 23:46:31.269 INFO kablam! warning: unused import: `OneTimeKey` Aug 10 23:46:31.269 INFO kablam! --> src/tokio/outbound_handlers/publish.rs:12:13 Aug 10 23:46:31.269 INFO kablam! | Aug 10 23:46:31.269 INFO kablam! 12 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple}; Aug 10 23:46:31.269 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.269 INFO kablam! Aug 10 23:46:31.269 INFO kablam! warning: unused import: `BoxFuture` Aug 10 23:46:31.269 INFO kablam! --> src/tokio/outbound_handlers/mod.rs:8:27 Aug 10 23:46:31.269 INFO kablam! | Aug 10 23:46:31.269 INFO kablam! 8 | use tokio::{RequestTuple, BoxFuture}; Aug 10 23:46:31.269 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.269 INFO kablam! Aug 10 23:46:31.269 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.269 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:3:16 Aug 10 23:46:31.269 INFO kablam! | Aug 10 23:46:31.269 INFO kablam! 3 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.269 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.269 INFO kablam! Aug 10 23:46:31.269 INFO kablam! warning: unused import: `AsyncSink` Aug 10 23:46:31.269 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:28 Aug 10 23:46:31.269 INFO kablam! | Aug 10 23:46:31.269 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.270 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.270 INFO kablam! Aug 10 23:46:31.270 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Aug 10 23:46:31.270 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:6:5 Aug 10 23:46:31.270 INFO kablam! | Aug 10 23:46:31.270 INFO kablam! 6 | use futures::unsync::mpsc::UnboundedSender; Aug 10 23:46:31.270 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.270 INFO kablam! Aug 10 23:46:31.270 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.270 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:7:5 Aug 10 23:46:31.270 INFO kablam! | Aug 10 23:46:31.270 INFO kablam! 7 | use take::Take; Aug 10 23:46:31.270 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.270 INFO kablam! Aug 10 23:46:31.270 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.270 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:9:5 Aug 10 23:46:31.270 INFO kablam! | Aug 10 23:46:31.270 INFO kablam! 9 | use bincode; Aug 10 23:46:31.270 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.273 INFO kablam! Aug 10 23:46:31.273 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Aug 10 23:46:31.273 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:11:25 Aug 10 23:46:31.273 INFO kablam! | Aug 10 23:46:31.274 INFO kablam! 11 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.274 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.274 INFO kablam! 12 | PacketId, TopicName}; Aug 10 23:46:31.274 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.274 INFO kablam! Aug 10 23:46:31.274 INFO kablam! warning: unused imports: `ResultExt`, `Result` Aug 10 23:46:31.274 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:14:21 Aug 10 23:46:31.274 INFO kablam! | Aug 10 23:46:31.274 INFO kablam! 14 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.274 INFO kablam! | ^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.275 INFO kablam! Aug 10 23:46:31.275 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple` Aug 10 23:46:31.275 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:17:25 Aug 10 23:46:31.275 INFO kablam! | Aug 10 23:46:31.275 INFO kablam! 17 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Aug 10 23:46:31.275 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.275 INFO kablam! Aug 10 23:46:31.275 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.275 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:4:16 Aug 10 23:46:31.275 INFO kablam! | Aug 10 23:46:31.275 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.276 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.276 INFO kablam! Aug 10 23:46:31.276 INFO kablam! warning: unused import: `AsyncSink` Aug 10 23:46:31.276 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:28 Aug 10 23:46:31.276 INFO kablam! | Aug 10 23:46:31.276 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.276 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.276 INFO kablam! Aug 10 23:46:31.276 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.277 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:6:5 Aug 10 23:46:31.277 INFO kablam! | Aug 10 23:46:31.277 INFO kablam! 6 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.277 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.277 INFO kablam! Aug 10 23:46:31.277 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Aug 10 23:46:31.277 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:7:5 Aug 10 23:46:31.277 INFO kablam! | Aug 10 23:46:31.277 INFO kablam! 7 | use futures::unsync::mpsc::UnboundedSender; Aug 10 23:46:31.277 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.278 INFO kablam! Aug 10 23:46:31.278 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.278 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:8:5 Aug 10 23:46:31.278 INFO kablam! | Aug 10 23:46:31.278 INFO kablam! 8 | use take::Take; Aug 10 23:46:31.278 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.278 INFO kablam! Aug 10 23:46:31.278 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.278 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:10:5 Aug 10 23:46:31.278 INFO kablam! | Aug 10 23:46:31.279 INFO kablam! 10 | use bincode; Aug 10 23:46:31.279 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.279 INFO kablam! Aug 10 23:46:31.279 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService`, `TopicName` Aug 10 23:46:31.279 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:12:25 Aug 10 23:46:31.279 INFO kablam! | Aug 10 23:46:31.279 INFO kablam! 12 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.279 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.279 INFO kablam! 13 | PacketId, TopicName}; Aug 10 23:46:31.279 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.280 INFO kablam! Aug 10 23:46:31.280 INFO kablam! warning: unused imports: `ResultExt`, `Result` Aug 10 23:46:31.280 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:15:21 Aug 10 23:46:31.280 INFO kablam! | Aug 10 23:46:31.280 INFO kablam! 15 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.280 INFO kablam! | ^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.280 INFO kablam! Aug 10 23:46:31.280 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.280 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:18:25 Aug 10 23:46:31.280 INFO kablam! | Aug 10 23:46:31.281 INFO kablam! 18 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Aug 10 23:46:31.281 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.281 INFO kablam! Aug 10 23:46:31.281 INFO kablam! warning: unused import: `std::ops::Deref` Aug 10 23:46:31.281 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:2:5 Aug 10 23:46:31.281 INFO kablam! | Aug 10 23:46:31.281 INFO kablam! 2 | use std::ops::Deref; Aug 10 23:46:31.281 INFO kablam! | ^^^^^^^^^^^^^^^ Aug 10 23:46:31.281 INFO kablam! Aug 10 23:46:31.282 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.282 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:4:16 Aug 10 23:46:31.282 INFO kablam! | Aug 10 23:46:31.282 INFO kablam! 4 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.282 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.282 INFO kablam! Aug 10 23:46:31.282 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Aug 10 23:46:31.282 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:15 Aug 10 23:46:31.282 INFO kablam! | Aug 10 23:46:31.282 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.282 INFO kablam! | ^^^^ ^^^^^^^^^ Aug 10 23:46:31.283 INFO kablam! Aug 10 23:46:31.283 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.285 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:7:5 Aug 10 23:46:31.285 INFO kablam! | Aug 10 23:46:31.285 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.285 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.285 INFO kablam! Aug 10 23:46:31.286 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Aug 10 23:46:31.286 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:8:5 Aug 10 23:46:31.286 INFO kablam! | Aug 10 23:46:31.286 INFO kablam! 8 | use futures::unsync::mpsc::UnboundedSender; Aug 10 23:46:31.286 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.286 INFO kablam! Aug 10 23:46:31.286 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.286 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:9:5 Aug 10 23:46:31.286 INFO kablam! | Aug 10 23:46:31.286 INFO kablam! 9 | use take::Take; Aug 10 23:46:31.287 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.287 INFO kablam! Aug 10 23:46:31.287 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 Aug 10 23:46:31.287 INFO kablam! --> src/types.rs:3:5 Aug 10 23:46:31.287 INFO kablam! | Aug 10 23:46:31.287 INFO kablam! 3 | use futures::future::BoxFuture; Aug 10 23:46:31.287 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.287 INFO kablam! | Aug 10 23:46:31.287 INFO kablam! = note: #[warn(deprecated)] on by default Aug 10 23:46:31.287 INFO kablam! Aug 10 23:46:31.287 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.288 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:11:5 Aug 10 23:46:31.288 INFO kablam! | Aug 10 23:46:31.288 INFO kablam! 11 | use bincode; Aug 10 23:46:31.288 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.288 INFO kablam! Aug 10 23:46:31.288 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 Aug 10 23:46:31.289 INFO kablam! --> src/types.rs:5:5 Aug 10 23:46:31.289 INFO kablam! | Aug 10 23:46:31.289 INFO kablam! 5 | use futures::stream::BoxStream; Aug 10 23:46:31.289 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.289 INFO kablam! Aug 10 23:46:31.289 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `MqttPacket`, `PacketId`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Aug 10 23:46:31.289 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:13:13 Aug 10 23:46:31.289 INFO kablam! | Aug 10 23:46:31.289 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.290 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.290 INFO kablam! 14 | PacketId, TopicName}; Aug 10 23:46:31.290 INFO kablam! | ^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.290 INFO kablam! Aug 10 23:46:31.290 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 Aug 10 23:46:31.290 INFO kablam! --> src/types.rs:7:29 Aug 10 23:46:31.290 INFO kablam! | Aug 10 23:46:31.290 INFO kablam! 7 | pub type BoxMqttFuture = BoxFuture; Aug 10 23:46:31.291 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.291 INFO kablam! Aug 10 23:46:31.291 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Aug 10 23:46:31.291 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:16:21 Aug 10 23:46:31.291 INFO kablam! | Aug 10 23:46:31.291 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.291 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.291 INFO kablam! Aug 10 23:46:31.292 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 Aug 10 23:46:31.293 INFO kablam! --> src/types.rs:9:29 Aug 10 23:46:31.293 INFO kablam! | Aug 10 23:46:31.293 INFO kablam! 9 | pub type BoxMqttStream = BoxStream; Aug 10 23:46:31.293 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.293 INFO kablam! Aug 10 23:46:31.293 INFO kablam! warning: unused import: `errors::proto::ErrorKind as ProtoErrorKind` Aug 10 23:46:31.293 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:17:5 Aug 10 23:46:31.293 INFO kablam! | Aug 10 23:46:31.293 INFO kablam! 17 | use errors::proto::ErrorKind as ProtoErrorKind; Aug 10 23:46:31.294 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.294 INFO kablam! Aug 10 23:46:31.294 INFO kablam! warning: unused imports: `BoxFuture`, `PublishState`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.295 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:19:25 Aug 10 23:46:31.295 INFO kablam! | Aug 10 23:46:31.295 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Aug 10 23:46:31.295 INFO kablam! | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.295 INFO kablam! Aug 10 23:46:31.295 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Aug 10 23:46:31.295 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:1:5 Aug 10 23:46:31.295 INFO kablam! | Aug 10 23:46:31.295 INFO kablam! 1 | use std::collections::hash_map::Entry; Aug 10 23:46:31.296 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.296 INFO kablam! Aug 10 23:46:31.296 INFO kablam! warning: unused import: `std::ops::Deref` Aug 10 23:46:31.296 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:2:5 Aug 10 23:46:31.296 INFO kablam! | Aug 10 23:46:31.296 INFO kablam! 2 | use std::ops::Deref; Aug 10 23:46:31.296 INFO kablam! | ^^^^^^^^^^^^^^^ Aug 10 23:46:31.296 INFO kablam! Aug 10 23:46:31.296 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.297 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:5:16 Aug 10 23:46:31.297 INFO kablam! | Aug 10 23:46:31.297 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.297 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.297 INFO kablam! Aug 10 23:46:31.297 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Aug 10 23:46:31.297 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:28 Aug 10 23:46:31.297 INFO kablam! | Aug 10 23:46:31.297 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.297 INFO kablam! | ^^^^^^^^^ ^^^^ Aug 10 23:46:31.298 INFO kablam! Aug 10 23:46:31.298 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.298 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:7:5 Aug 10 23:46:31.298 INFO kablam! | Aug 10 23:46:31.298 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.298 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.298 INFO kablam! Aug 10 23:46:31.298 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.298 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:9:5 Aug 10 23:46:31.299 INFO kablam! | Aug 10 23:46:31.299 INFO kablam! 9 | use take::Take; Aug 10 23:46:31.299 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.299 INFO kablam! Aug 10 23:46:31.299 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.299 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:11:5 Aug 10 23:46:31.299 INFO kablam! | Aug 10 23:46:31.299 INFO kablam! 11 | use bincode; Aug 10 23:46:31.299 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.299 INFO kablam! Aug 10 23:46:31.299 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType` Aug 10 23:46:31.300 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:13:25 Aug 10 23:46:31.300 INFO kablam! | Aug 10 23:46:31.300 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.300 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.300 INFO kablam! Aug 10 23:46:31.300 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Aug 10 23:46:31.300 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:16:21 Aug 10 23:46:31.300 INFO kablam! | Aug 10 23:46:31.301 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.301 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.301 INFO kablam! Aug 10 23:46:31.301 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.301 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:19:13 Aug 10 23:46:31.301 INFO kablam! | Aug 10 23:46:31.301 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Aug 10 23:46:31.301 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.301 INFO kablam! Aug 10 23:46:31.302 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Aug 10 23:46:31.302 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:1:5 Aug 10 23:46:31.302 INFO kablam! | Aug 10 23:46:31.302 INFO kablam! 1 | use std::collections::hash_map::Entry; Aug 10 23:46:31.302 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.302 INFO kablam! Aug 10 23:46:31.302 INFO kablam! warning: unused import: `std::ops::Deref` Aug 10 23:46:31.302 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:2:5 Aug 10 23:46:31.302 INFO kablam! | Aug 10 23:46:31.302 INFO kablam! 2 | use std::ops::Deref; Aug 10 23:46:31.303 INFO kablam! | ^^^^^^^^^^^^^^^ Aug 10 23:46:31.303 INFO kablam! Aug 10 23:46:31.303 INFO kablam! warning: unused import: `bytes::Bytes` Aug 10 23:46:31.303 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:4:5 Aug 10 23:46:31.303 INFO kablam! | Aug 10 23:46:31.303 INFO kablam! 4 | use bytes::Bytes; Aug 10 23:46:31.303 INFO kablam! | ^^^^^^^^^^^^ Aug 10 23:46:31.303 INFO kablam! Aug 10 23:46:31.303 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.303 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:5:16 Aug 10 23:46:31.304 INFO kablam! | Aug 10 23:46:31.304 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.304 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.304 INFO kablam! Aug 10 23:46:31.304 INFO kablam! warning: unused imports: `AsyncSink`, `Poll` Aug 10 23:46:31.304 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:15 Aug 10 23:46:31.304 INFO kablam! | Aug 10 23:46:31.304 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.304 INFO kablam! | ^^^^ ^^^^^^^^^ Aug 10 23:46:31.304 INFO kablam! Aug 10 23:46:31.305 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.305 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:8:5 Aug 10 23:46:31.305 INFO kablam! | Aug 10 23:46:31.305 INFO kablam! 8 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.305 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.305 INFO kablam! Aug 10 23:46:31.305 INFO kablam! warning: unused import: `futures::unsync::mpsc::UnboundedSender` Aug 10 23:46:31.305 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:9:5 Aug 10 23:46:31.305 INFO kablam! | Aug 10 23:46:31.305 INFO kablam! 9 | use futures::unsync::mpsc::UnboundedSender; Aug 10 23:46:31.306 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.306 INFO kablam! Aug 10 23:46:31.306 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.306 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:10:5 Aug 10 23:46:31.306 INFO kablam! | Aug 10 23:46:31.306 INFO kablam! 10 | use take::Take; Aug 10 23:46:31.306 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.306 INFO kablam! Aug 10 23:46:31.306 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.307 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:12:5 Aug 10 23:46:31.307 INFO kablam! | Aug 10 23:46:31.307 INFO kablam! 12 | use bincode; Aug 10 23:46:31.307 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.307 INFO kablam! Aug 10 23:46:31.307 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Aug 10 23:46:31.308 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:14:25 Aug 10 23:46:31.308 INFO kablam! | Aug 10 23:46:31.308 INFO kablam! 14 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.308 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.308 INFO kablam! 15 | PacketId, TopicName}; Aug 10 23:46:31.308 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.308 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Aug 10 23:46:31.308 INFO kablam! --> src/tokio/mod.rs:12:5 Aug 10 23:46:31.309 INFO kablam! | Aug 10 23:46:31.309 INFO kablam! 12 | use tokio_io::codec::Framed; Aug 10 23:46:31.309 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.309 INFO kablam! Aug 10 23:46:31.309 INFO kablam! Aug 10 23:46:31.309 INFO kablam! warning: unused import: `Result` Aug 10 23:46:31.309 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:17:21 Aug 10 23:46:31.309 INFO kablam! | Aug 10 23:46:31.309 INFO kablam! 17 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.309 INFO kablam! | ^^^^^^ Aug 10 23:46:31.310 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Aug 10 23:46:31.310 INFO kablam! --> src/tokio/mod.rs:27:40 Aug 10 23:46:31.310 INFO kablam! | Aug 10 23:46:31.310 INFO kablam! 27 | type MqttFramedReader = SplitStream>; Aug 10 23:46:31.310 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.310 INFO kablam! Aug 10 23:46:31.310 INFO kablam! Aug 10 23:46:31.310 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Aug 10 23:46:31.310 INFO kablam! --> src/tokio/mod.rs:28:38 Aug 10 23:46:31.310 INFO kablam! | Aug 10 23:46:31.311 INFO kablam! 28 | type MqttFramedWriter = SplitSink>; Aug 10 23:46:31.311 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.311 INFO kablam! Aug 10 23:46:31.311 INFO kablam! warning: unused imports: `BoxFuture`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.311 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:20:13 Aug 10 23:46:31.311 INFO kablam! | Aug 10 23:46:31.311 INFO kablam! 20 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture}; Aug 10 23:46:31.311 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.311 INFO kablam! Aug 10 23:46:31.311 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Aug 10 23:46:31.312 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:1:5 Aug 10 23:46:31.312 INFO kablam! | Aug 10 23:46:31.312 INFO kablam! 1 | use std::collections::hash_map::Entry; Aug 10 23:46:31.312 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.312 INFO kablam! Aug 10 23:46:31.312 INFO kablam! warning: unused import: `std::ops::Deref` Aug 10 23:46:31.312 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:2:5 Aug 10 23:46:31.312 INFO kablam! | Aug 10 23:46:31.312 INFO kablam! 2 | use std::ops::Deref; Aug 10 23:46:31.312 INFO kablam! | ^^^^^^^^^^^^^^^ Aug 10 23:46:31.312 INFO kablam! Aug 10 23:46:31.312 INFO kablam! warning: unused import: `bytes::Bytes` Aug 10 23:46:31.312 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:4:5 Aug 10 23:46:31.313 INFO kablam! | Aug 10 23:46:31.313 INFO kablam! 4 | use bytes::Bytes; Aug 10 23:46:31.313 INFO kablam! | ^^^^^^^^^^^^ Aug 10 23:46:31.313 INFO kablam! Aug 10 23:46:31.313 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.313 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:5:16 Aug 10 23:46:31.313 INFO kablam! | Aug 10 23:46:31.313 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.313 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.313 INFO kablam! Aug 10 23:46:31.313 INFO kablam! warning: unused import: `AsyncSink` Aug 10 23:46:31.313 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:28 Aug 10 23:46:31.313 INFO kablam! | Aug 10 23:46:31.313 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.313 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.313 INFO kablam! Aug 10 23:46:31.313 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.313 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:7:5 Aug 10 23:46:31.313 INFO kablam! | Aug 10 23:46:31.313 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.313 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.313 INFO kablam! Aug 10 23:46:31.314 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.314 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:9:5 Aug 10 23:46:31.314 INFO kablam! | Aug 10 23:46:31.314 INFO kablam! 9 | use take::Take; Aug 10 23:46:31.314 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.314 INFO kablam! Aug 10 23:46:31.314 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `Payload`, `QualityOfService`, `TopicName` Aug 10 23:46:31.314 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:13:25 Aug 10 23:46:31.314 INFO kablam! | Aug 10 23:46:31.314 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.314 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.314 INFO kablam! 14 | PacketId, TopicName}; Aug 10 23:46:31.314 INFO kablam! | ^^^^^^^^^ Aug 10 23:46:31.314 INFO kablam! Aug 10 23:46:31.314 INFO kablam! warning: unused import: `Result` Aug 10 23:46:31.314 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:16:21 Aug 10 23:46:31.314 INFO kablam! | Aug 10 23:46:31.314 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.314 INFO kablam! | ^^^^^^ Aug 10 23:46:31.314 INFO kablam! Aug 10 23:46:31.314 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.314 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:19:13 Aug 10 23:46:31.314 INFO kablam! | Aug 10 23:46:31.315 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Aug 10 23:46:31.315 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.315 INFO kablam! Aug 10 23:46:31.315 INFO kablam! warning: unused import: `std::collections::hash_map::Entry` Aug 10 23:46:31.315 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:1:5 Aug 10 23:46:31.315 INFO kablam! | Aug 10 23:46:31.315 INFO kablam! 1 | use std::collections::hash_map::Entry; Aug 10 23:46:31.315 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.315 INFO kablam! Aug 10 23:46:31.315 INFO kablam! warning: unused import: `std::ops::Deref` Aug 10 23:46:31.315 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:2:5 Aug 10 23:46:31.315 INFO kablam! | Aug 10 23:46:31.315 INFO kablam! 2 | use std::ops::Deref; Aug 10 23:46:31.315 INFO kablam! | ^^^^^^^^^^^^^^^ Aug 10 23:46:31.315 INFO kablam! Aug 10 23:46:31.315 INFO kablam! warning: unused imports: `AsyncRead`, `AsyncWrite` Aug 10 23:46:31.315 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:5:16 Aug 10 23:46:31.315 INFO kablam! | Aug 10 23:46:31.315 INFO kablam! 5 | use tokio_io::{AsyncRead, AsyncWrite}; Aug 10 23:46:31.315 INFO kablam! | ^^^^^^^^^ ^^^^^^^^^^ Aug 10 23:46:31.315 INFO kablam! Aug 10 23:46:31.315 INFO kablam! warning: unused imports: `AsyncSink`, `Sink` Aug 10 23:46:31.316 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:28 Aug 10 23:46:31.316 INFO kablam! | Aug 10 23:46:31.316 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:31.316 INFO kablam! | ^^^^^^^^^ ^^^^ Aug 10 23:46:31.316 INFO kablam! Aug 10 23:46:31.316 INFO kablam! warning: unused import: `futures::sync::mpsc::unbounded` Aug 10 23:46:31.316 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:7:5 Aug 10 23:46:31.316 INFO kablam! | Aug 10 23:46:31.316 INFO kablam! 7 | use futures::sync::mpsc::unbounded; Aug 10 23:46:31.316 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.316 INFO kablam! Aug 10 23:46:31.316 INFO kablam! warning: unused import: `take::Take` Aug 10 23:46:31.316 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:9:5 Aug 10 23:46:31.316 INFO kablam! | Aug 10 23:46:31.316 INFO kablam! 9 | use take::Take; Aug 10 23:46:31.316 INFO kablam! | ^^^^^^^^^^ Aug 10 23:46:31.316 INFO kablam! Aug 10 23:46:31.316 INFO kablam! warning: unused import: `bincode` Aug 10 23:46:31.316 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:11:5 Aug 10 23:46:31.316 INFO kablam! | Aug 10 23:46:31.316 INFO kablam! 11 | use bincode; Aug 10 23:46:31.316 INFO kablam! | ^^^^^^^ Aug 10 23:46:31.317 INFO kablam! Aug 10 23:46:31.317 INFO kablam! warning: unused imports: `ConnectAckFlags`, `ConnectReturnCode`, `PacketType`, `QualityOfService` Aug 10 23:46:31.317 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:13:25 Aug 10 23:46:31.317 INFO kablam! | Aug 10 23:46:31.317 INFO kablam! 13 | use proto::{MqttPacket, PacketType, QualityOfService, Payload, ConnectReturnCode, ConnectAckFlags, Aug 10 23:46:31.317 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^ Aug 10 23:46:31.317 INFO kablam! Aug 10 23:46:31.317 INFO kablam! warning: unused imports: `ErrorKind`, `ResultExt`, `Result` Aug 10 23:46:31.317 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:16:21 Aug 10 23:46:31.317 INFO kablam! | Aug 10 23:46:31.317 INFO kablam! 16 | use errors::{Error, Result, ErrorKind, ResultExt}; Aug 10 23:46:31.317 INFO kablam! | ^^^^^^ ^^^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.317 INFO kablam! Aug 10 23:46:31.317 INFO kablam! warning: unused imports: `BoxFuture`, `ClientReturn`, `OneTimeKey`, `RequestTuple`, `SubItem`, `TopicFilter` Aug 10 23:46:31.317 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:19:13 Aug 10 23:46:31.317 INFO kablam! | Aug 10 23:46:31.317 INFO kablam! 19 | use tokio::{OneTimeKey, PublishState, ClientReturn, RequestTuple, TopicFilter, SubItem, BoxFuture, Aug 10 23:46:31.317 INFO kablam! | ^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^ ^^^^^^^^^ Aug 10 23:46:31.317 INFO kablam! Aug 10 23:46:31.368 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 Aug 10 23:46:31.368 INFO kablam! --> src/types.rs:3:5 Aug 10 23:46:31.368 INFO kablam! | Aug 10 23:46:31.368 INFO kablam! 3 | use futures::future::BoxFuture; Aug 10 23:46:31.368 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.368 INFO kablam! | Aug 10 23:46:31.368 INFO kablam! = note: #[warn(deprecated)] on by default Aug 10 23:46:31.368 INFO kablam! Aug 10 23:46:31.368 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 Aug 10 23:46:31.368 INFO kablam! --> src/types.rs:5:5 Aug 10 23:46:31.368 INFO kablam! | Aug 10 23:46:31.368 INFO kablam! 5 | use futures::stream::BoxStream; Aug 10 23:46:31.368 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.369 INFO kablam! Aug 10 23:46:31.369 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 Aug 10 23:46:31.369 INFO kablam! --> src/types.rs:7:29 Aug 10 23:46:31.369 INFO kablam! | Aug 10 23:46:31.369 INFO kablam! 7 | pub type BoxMqttFuture = BoxFuture; Aug 10 23:46:31.369 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.369 INFO kablam! Aug 10 23:46:31.369 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 Aug 10 23:46:31.369 INFO kablam! --> src/types.rs:9:29 Aug 10 23:46:31.369 INFO kablam! | Aug 10 23:46:31.369 INFO kablam! 9 | pub type BoxMqttStream = BoxStream; Aug 10 23:46:31.369 INFO kablam! | ^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.369 INFO kablam! Aug 10 23:46:31.369 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Aug 10 23:46:31.369 INFO kablam! --> src/tokio/mod.rs:12:5 Aug 10 23:46:31.369 INFO kablam! | Aug 10 23:46:31.369 INFO kablam! 12 | use tokio_io::codec::Framed; Aug 10 23:46:31.369 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.370 INFO kablam! Aug 10 23:46:31.370 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Aug 10 23:46:31.370 INFO kablam! --> src/tokio/mod.rs:27:40 Aug 10 23:46:31.370 INFO kablam! | Aug 10 23:46:31.370 INFO kablam! 27 | type MqttFramedReader = SplitStream>; Aug 10 23:46:31.370 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.370 INFO kablam! Aug 10 23:46:31.370 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec Aug 10 23:46:31.370 INFO kablam! --> src/tokio/mod.rs:28:38 Aug 10 23:46:31.370 INFO kablam! | Aug 10 23:46:31.370 INFO kablam! 28 | type MqttFramedWriter = SplitSink>; Aug 10 23:46:31.370 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:31.370 INFO kablam! Aug 10 23:46:32.340 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Aug 10 23:46:32.340 INFO kablam! --> src/proto/types.rs:271:13 Aug 10 23:46:32.340 INFO kablam! | Aug 10 23:46:32.340 INFO kablam! 271 | out.put_u16::(self.len() as u16); Aug 10 23:46:32.340 INFO kablam! | ^^^^^^^ Aug 10 23:46:32.341 INFO kablam! Aug 10 23:46:32.486 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Aug 10 23:46:32.486 INFO kablam! --> src/proto/types.rs:271:13 Aug 10 23:46:32.486 INFO kablam! | Aug 10 23:46:32.486 INFO kablam! 271 | out.put_u16::(self.len() as u16); Aug 10 23:46:32.486 INFO kablam! | ^^^^^^^ Aug 10 23:46:32.487 INFO kablam! Aug 10 23:46:32.856 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Aug 10 23:46:32.857 INFO kablam! --> src/proto/headers.rs:135:40 Aug 10 23:46:32.857 INFO kablam! | Aug 10 23:46:32.857 INFO kablam! 135 | Ok(PacketId(raw.into_buf().get_u16::())) Aug 10 23:46:32.857 INFO kablam! | ^^^^^^^ Aug 10 23:46:32.857 INFO kablam! Aug 10 23:46:32.859 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Aug 10 23:46:32.859 INFO kablam! --> src/proto/headers.rs:140:13 Aug 10 23:46:32.859 INFO kablam! | Aug 10 23:46:32.859 INFO kablam! 140 | out.put_u16::(self.0); Aug 10 23:46:32.859 INFO kablam! | ^^^^^^^ Aug 10 23:46:32.859 INFO kablam! Aug 10 23:46:32.863 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Aug 10 23:46:32.863 INFO kablam! --> src/proto/headers.rs:170:41 Aug 10 23:46:32.863 INFO kablam! | Aug 10 23:46:32.863 INFO kablam! 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Aug 10 23:46:32.863 INFO kablam! | ^^^^^^^ Aug 10 23:46:32.863 INFO kablam! Aug 10 23:46:32.864 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Aug 10 23:46:32.864 INFO kablam! --> src/proto/headers.rs:175:13 Aug 10 23:46:32.864 INFO kablam! | Aug 10 23:46:32.864 INFO kablam! 175 | out.put_u16::(self.0); Aug 10 23:46:32.864 INFO kablam! | ^^^^^^^ Aug 10 23:46:32.864 INFO kablam! Aug 10 23:46:32.864 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Aug 10 23:46:32.864 INFO kablam! --> src/proto/headers.rs:135:40 Aug 10 23:46:32.864 INFO kablam! | Aug 10 23:46:32.864 INFO kablam! 135 | Ok(PacketId(raw.into_buf().get_u16::())) Aug 10 23:46:32.864 INFO kablam! | ^^^^^^^ Aug 10 23:46:32.864 INFO kablam! Aug 10 23:46:32.865 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Aug 10 23:46:32.865 INFO kablam! --> src/proto/headers.rs:140:13 Aug 10 23:46:32.865 INFO kablam! | Aug 10 23:46:32.865 INFO kablam! 140 | out.put_u16::(self.0); Aug 10 23:46:32.865 INFO kablam! | ^^^^^^^ Aug 10 23:46:32.865 INFO kablam! Aug 10 23:46:32.867 INFO kablam! warning: use of deprecated item 'bytes::Buf::get_u16': use get_u16_be or get_u16_le Aug 10 23:46:32.867 INFO kablam! --> src/proto/headers.rs:170:41 Aug 10 23:46:32.867 INFO kablam! | Aug 10 23:46:32.867 INFO kablam! 170 | Ok(KeepAlive(raw.into_buf().get_u16::())) Aug 10 23:46:32.867 INFO kablam! | ^^^^^^^ Aug 10 23:46:32.867 INFO kablam! Aug 10 23:46:32.868 INFO kablam! warning: use of deprecated item 'bytes::BufMut::put_u16': use put_u16_be or put_u16_le Aug 10 23:46:32.868 INFO kablam! --> src/proto/headers.rs:175:13 Aug 10 23:46:32.868 INFO kablam! | Aug 10 23:46:32.868 INFO kablam! 175 | out.put_u16::(self.0); Aug 10 23:46:32.868 INFO kablam! | ^^^^^^^ Aug 10 23:46:32.868 INFO kablam! Aug 10 23:46:32.919 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 Aug 10 23:46:32.919 INFO kablam! --> src/client.rs:223:55 Aug 10 23:46:32.919 INFO kablam! | Aug 10 23:46:32.919 INFO kablam! 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Aug 10 23:46:32.919 INFO kablam! | ^^^^^ Aug 10 23:46:32.920 INFO kablam! Aug 10 23:46:32.940 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 Aug 10 23:46:32.940 INFO kablam! --> src/client.rs:266:63 Aug 10 23:46:32.940 INFO kablam! | Aug 10 23:46:32.941 INFO kablam! 266 | client.request(connect).into_future().map(|_| ()).boxed() Aug 10 23:46:32.941 INFO kablam! | ^^^^^ Aug 10 23:46:32.941 INFO kablam! Aug 10 23:46:32.952 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 Aug 10 23:46:32.952 INFO kablam! --> src/client.rs:223:55 Aug 10 23:46:32.952 INFO kablam! | Aug 10 23:46:32.952 INFO kablam! 223 | Some(Ok((s, _))) => Ok(Some(s.boxed())), Aug 10 23:46:32.952 INFO kablam! | ^^^^^ Aug 10 23:46:32.952 INFO kablam! Aug 10 23:46:32.972 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 Aug 10 23:46:32.972 INFO kablam! --> src/client.rs:266:63 Aug 10 23:46:32.972 INFO kablam! | Aug 10 23:46:32.972 INFO kablam! 266 | client.request(connect).into_future().map(|_| ()).boxed() Aug 10 23:46:32.972 INFO kablam! | ^^^^^ Aug 10 23:46:32.972 INFO kablam! Aug 10 23:46:33.063 INFO kablam! warning: use of deprecated item '>::send': renamed to `unbounded_send` Aug 10 23:46:33.063 INFO kablam! --> src/tokio/mqtt_loop.rs:54:32 Aug 10 23:46:33.063 INFO kablam! | Aug 10 23:46:33.063 INFO kablam! 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Aug 10 23:46:33.063 INFO kablam! | ^^^^ Aug 10 23:46:33.063 INFO kablam! Aug 10 23:46:33.073 INFO kablam! warning: use of deprecated item '>::send': renamed to `unbounded_send` Aug 10 23:46:33.073 INFO kablam! --> src/tokio/mqtt_loop.rs:54:32 Aug 10 23:46:33.073 INFO kablam! | Aug 10 23:46:33.073 INFO kablam! 54 | if let Err(e) = sender.send(req).chain_err(|| ErrorKind::LoopCommsError) { Aug 10 23:46:33.073 INFO kablam! | ^^^^ Aug 10 23:46:33.073 INFO kablam! Aug 10 23:46:33.073 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 Aug 10 23:46:33.073 INFO kablam! --> src/tokio/mqtt_loop.rs:60:47 Aug 10 23:46:33.073 INFO kablam! | Aug 10 23:46:33.073 INFO kablam! 60 | Ok((next_state(sender), Ok(rx.boxed()))) Aug 10 23:46:33.073 INFO kablam! | ^^^^^ Aug 10 23:46:33.073 INFO kablam! Aug 10 23:46:33.075 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 Aug 10 23:46:33.075 INFO kablam! --> src/tokio/mqtt_loop.rs:60:47 Aug 10 23:46:33.075 INFO kablam! | Aug 10 23:46:33.075 INFO kablam! 60 | Ok((next_state(sender), Ok(rx.boxed()))) Aug 10 23:46:33.075 INFO kablam! | ^^^^^ Aug 10 23:46:33.075 INFO kablam! Aug 10 23:46:33.087 INFO kablam! warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Aug 10 23:46:33.087 INFO kablam! --> src/tokio/mqtt_loop.rs:266:34 Aug 10 23:46:33.087 INFO kablam! | Aug 10 23:46:33.087 INFO kablam! 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Aug 10 23:46:33.087 INFO kablam! | ^^^^^^ Aug 10 23:46:33.087 INFO kablam! Aug 10 23:46:33.092 INFO kablam! warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead Aug 10 23:46:33.092 INFO kablam! --> src/tokio/mqtt_loop.rs:266:34 Aug 10 23:46:33.092 INFO kablam! | Aug 10 23:46:33.092 INFO kablam! 266 | let (fwrite, fread) = io.framed(MqttCodec).split(); Aug 10 23:46:33.092 INFO kablam! | ^^^^^^ Aug 10 23:46:33.093 INFO kablam! Aug 10 23:46:33.114 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 Aug 10 23:46:33.114 INFO kablam! --> src/tokio/mqtt_loop.rs:317:14 Aug 10 23:46:33.114 INFO kablam! | Aug 10 23:46:33.114 INFO kablam! 317 | .boxed() Aug 10 23:46:33.114 INFO kablam! | ^^^^^ Aug 10 23:46:33.114 INFO kablam! Aug 10 23:46:33.128 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 Aug 10 23:46:33.128 INFO kablam! --> src/tokio/mqtt_loop.rs:317:14 Aug 10 23:46:33.128 INFO kablam! | Aug 10 23:46:33.128 INFO kablam! 317 | .boxed() Aug 10 23:46:33.128 INFO kablam! | ^^^^^ Aug 10 23:46:33.128 INFO kablam! Aug 10 23:46:33.136 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 Aug 10 23:46:33.137 INFO kablam! --> src/tokio/mqtt_loop.rs:519:42 Aug 10 23:46:33.137 INFO kablam! | Aug 10 23:46:33.137 INFO kablam! 519 | .boxed(), Aug 10 23:46:33.137 INFO kablam! | ^^^^^ Aug 10 23:46:33.137 INFO kablam! Aug 10 23:46:33.159 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 Aug 10 23:46:33.159 INFO kablam! --> src/tokio/response.rs:83:40 Aug 10 23:46:33.159 INFO kablam! | Aug 10 23:46:33.159 INFO kablam! 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Aug 10 23:46:33.159 INFO kablam! | ^^^^^ Aug 10 23:46:33.159 INFO kablam! Aug 10 23:46:33.160 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 Aug 10 23:46:33.160 INFO kablam! --> src/tokio/mqtt_loop.rs:519:42 Aug 10 23:46:33.160 INFO kablam! | Aug 10 23:46:33.160 INFO kablam! 519 | .boxed(), Aug 10 23:46:33.160 INFO kablam! | ^^^^^ Aug 10 23:46:33.160 INFO kablam! Aug 10 23:46:33.194 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 Aug 10 23:46:33.194 INFO kablam! --> src/tokio/response.rs:83:40 Aug 10 23:46:33.194 INFO kablam! | Aug 10 23:46:33.194 INFO kablam! 83 | vec![Ok((custom_rx.boxed(), QualityOfService::QoS0))], Aug 10 23:46:33.194 INFO kablam! | ^^^^^ Aug 10 23:46:33.194 INFO kablam! Aug 10 23:46:33.264 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 Aug 10 23:46:33.264 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Aug 10 23:46:33.264 INFO kablam! | Aug 10 23:46:33.264 INFO kablam! 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Aug 10 23:46:33.264 INFO kablam! | ^^^^^ Aug 10 23:46:33.264 INFO kablam! Aug 10 23:46:33.337 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 Aug 10 23:46:33.337 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:101:52 Aug 10 23:46:33.337 INFO kablam! | Aug 10 23:46:33.337 INFO kablam! 101 | collect.push(Ok((custom_rx.boxed(), sub.qos))); Aug 10 23:46:33.337 INFO kablam! | ^^^^^ Aug 10 23:46:33.337 INFO kablam! Aug 10 23:46:33.777 INFO kablam! warning: unused import: `Sink` Aug 10 23:46:33.777 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Aug 10 23:46:33.777 INFO kablam! | Aug 10 23:46:33.777 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.778 INFO kablam! | ^^^^ Aug 10 23:46:33.778 INFO kablam! Aug 10 23:46:33.778 INFO kablam! warning: unused import: `Sink` Aug 10 23:46:33.778 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Aug 10 23:46:33.778 INFO kablam! | Aug 10 23:46:33.778 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.778 INFO kablam! | ^^^^ Aug 10 23:46:33.778 INFO kablam! Aug 10 23:46:33.778 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.778 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Aug 10 23:46:33.778 INFO kablam! | Aug 10 23:46:33.778 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.778 INFO kablam! | ^^^^^^ Aug 10 23:46:33.778 INFO kablam! Aug 10 23:46:33.778 INFO kablam! warning: unused import: `Sink` Aug 10 23:46:33.778 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:39 Aug 10 23:46:33.778 INFO kablam! | Aug 10 23:46:33.778 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.778 INFO kablam! | ^^^^ Aug 10 23:46:33.778 INFO kablam! Aug 10 23:46:33.778 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.778 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:53 Aug 10 23:46:33.778 INFO kablam! | Aug 10 23:46:33.779 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.779 INFO kablam! | ^^^^^^ Aug 10 23:46:33.779 INFO kablam! Aug 10 23:46:33.779 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.779 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:53 Aug 10 23:46:33.779 INFO kablam! | Aug 10 23:46:33.779 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.779 INFO kablam! | ^^^^^^ Aug 10 23:46:33.779 INFO kablam! Aug 10 23:46:33.779 INFO kablam! warning: unused import: `Sink` Aug 10 23:46:33.779 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Aug 10 23:46:33.779 INFO kablam! | Aug 10 23:46:33.779 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.779 INFO kablam! | ^^^^ Aug 10 23:46:33.779 INFO kablam! Aug 10 23:46:33.779 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.779 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Aug 10 23:46:33.779 INFO kablam! | Aug 10 23:46:33.779 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.779 INFO kablam! | ^^^^^^ Aug 10 23:46:33.779 INFO kablam! Aug 10 23:46:33.779 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.779 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Aug 10 23:46:33.779 INFO kablam! | Aug 10 23:46:33.779 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.779 INFO kablam! | ^^^^^^ Aug 10 23:46:33.779 INFO kablam! Aug 10 23:46:33.779 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.779 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:53 Aug 10 23:46:33.779 INFO kablam! | Aug 10 23:46:33.780 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.780 INFO kablam! | ^^^^^^ Aug 10 23:46:33.780 INFO kablam! Aug 10 23:46:33.874 INFO kablam! warning: unused import: `Sink` Aug 10 23:46:33.874 INFO kablam! --> src/tokio/inbound_handlers/subscribe_ack.rs:4:39 Aug 10 23:46:33.874 INFO kablam! | Aug 10 23:46:33.874 INFO kablam! 4 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.874 INFO kablam! | ^^^^ Aug 10 23:46:33.874 INFO kablam! Aug 10 23:46:33.874 INFO kablam! warning: unused import: `Sink` Aug 10 23:46:33.874 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:39 Aug 10 23:46:33.874 INFO kablam! | Aug 10 23:46:33.874 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.874 INFO kablam! | ^^^^ Aug 10 23:46:33.874 INFO kablam! Aug 10 23:46:33.874 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.874 INFO kablam! --> src/tokio/inbound_handlers/unsubscribe_ack.rs:5:53 Aug 10 23:46:33.874 INFO kablam! | Aug 10 23:46:33.874 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.874 INFO kablam! | ^^^^^^ Aug 10 23:46:33.874 INFO kablam! Aug 10 23:46:33.874 INFO kablam! warning: unused import: `Sink` Aug 10 23:46:33.874 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:39 Aug 10 23:46:33.874 INFO kablam! | Aug 10 23:46:33.875 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.875 INFO kablam! | ^^^^ Aug 10 23:46:33.875 INFO kablam! Aug 10 23:46:33.875 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.875 INFO kablam! --> src/tokio/inbound_handlers/ping_response.rs:5:53 Aug 10 23:46:33.875 INFO kablam! | Aug 10 23:46:33.875 INFO kablam! 5 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.875 INFO kablam! | ^^^^^^ Aug 10 23:46:33.875 INFO kablam! Aug 10 23:46:33.875 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.875 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:6:53 Aug 10 23:46:33.875 INFO kablam! | Aug 10 23:46:33.875 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.875 INFO kablam! | ^^^^^^ Aug 10 23:46:33.875 INFO kablam! Aug 10 23:46:33.875 INFO kablam! warning: unused import: `Sink` Aug 10 23:46:33.875 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:39 Aug 10 23:46:33.875 INFO kablam! | Aug 10 23:46:33.875 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.875 INFO kablam! | ^^^^ Aug 10 23:46:33.875 INFO kablam! Aug 10 23:46:33.875 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.875 INFO kablam! --> src/tokio/inbound_handlers/publish_ack.rs:6:53 Aug 10 23:46:33.875 INFO kablam! | Aug 10 23:46:33.875 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.876 INFO kablam! | ^^^^^^ Aug 10 23:46:33.876 INFO kablam! Aug 10 23:46:33.876 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.876 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:6:53 Aug 10 23:46:33.876 INFO kablam! | Aug 10 23:46:33.876 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.876 INFO kablam! | ^^^^^^ Aug 10 23:46:33.876 INFO kablam! Aug 10 23:46:33.876 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:33.876 INFO kablam! --> src/tokio/inbound_handlers/publish_release.rs:6:53 Aug 10 23:46:33.876 INFO kablam! | Aug 10 23:46:33.876 INFO kablam! 6 | use futures::{Poll, Async, AsyncSink, Sink, Future, Stream}; Aug 10 23:46:33.876 INFO kablam! | ^^^^^^ Aug 10 23:46:33.876 INFO kablam! Aug 10 23:46:34.735 INFO kablam! warning: variable does not need to be mutable Aug 10 23:46:34.735 INFO kablam! --> src/tokio/mqtt_loop.rs:320:31 Aug 10 23:46:34.735 INFO kablam! | Aug 10 23:46:34.735 INFO kablam! 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Aug 10 23:46:34.735 INFO kablam! | ----^^^ Aug 10 23:46:34.735 INFO kablam! | | Aug 10 23:46:34.735 INFO kablam! | help: remove this `mut` Aug 10 23:46:34.736 INFO kablam! | Aug 10 23:46:34.736 INFO kablam! = note: #[warn(unused_mut)] on by default Aug 10 23:46:34.736 INFO kablam! Aug 10 23:46:34.788 INFO kablam! warning: variable does not need to be mutable Aug 10 23:46:34.788 INFO kablam! --> src/tokio/mqtt_loop.rs:320:31 Aug 10 23:46:34.788 INFO kablam! | Aug 10 23:46:34.788 INFO kablam! 320 | fn poll_queues(&mut self, mut res: SourceItem) -> Poll<(), ::tokio::SourceError> { Aug 10 23:46:34.788 INFO kablam! | ----^^^ Aug 10 23:46:34.788 INFO kablam! | | Aug 10 23:46:34.788 INFO kablam! | help: remove this `mut` Aug 10 23:46:34.788 INFO kablam! | Aug 10 23:46:34.788 INFO kablam! = note: #[warn(unused_mut)] on by default Aug 10 23:46:34.788 INFO kablam! Aug 10 23:46:35.536 INFO kablam! warning: unused `std::result::Result` which must be used Aug 10 23:46:35.536 INFO kablam! --> src/tokio/mqtt_loop.rs:571:17 Aug 10 23:46:35.536 INFO kablam! | Aug 10 23:46:35.536 INFO kablam! 571 | self.poll_queues(sourceitem); Aug 10 23:46:35.536 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:35.536 INFO kablam! | Aug 10 23:46:35.536 INFO kablam! = note: #[warn(unused_must_use)] on by default Aug 10 23:46:35.536 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Aug 10 23:46:35.536 INFO kablam! Aug 10 23:46:35.560 INFO kablam! warning: unused `std::result::Result` which must be used Aug 10 23:46:35.561 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:104:25 Aug 10 23:46:35.561 INFO kablam! | Aug 10 23:46:35.561 INFO kablam! 104 | / requester.unbounded_send(LoopRequest::Internal( Aug 10 23:46:35.561 INFO kablam! 105 | | MqttPacket::pub_ack_packet(*id), Aug 10 23:46:35.561 INFO kablam! 106 | | )); Aug 10 23:46:35.561 INFO kablam! | |___________________________^ Aug 10 23:46:35.564 INFO kablam! | Aug 10 23:46:35.564 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Aug 10 23:46:35.564 INFO kablam! Aug 10 23:46:35.564 INFO kablam! warning: unused `std::result::Result` which must be used Aug 10 23:46:35.564 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:128:29 Aug 10 23:46:35.564 INFO kablam! | Aug 10 23:46:35.564 INFO kablam! 128 | / requester.unbounded_send( Aug 10 23:46:35.564 INFO kablam! 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Aug 10 23:46:35.564 INFO kablam! 130 | | ); Aug 10 23:46:35.564 INFO kablam! | |______________________________^ Aug 10 23:46:35.565 INFO kablam! | Aug 10 23:46:35.565 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Aug 10 23:46:35.565 INFO kablam! Aug 10 23:46:35.577 INFO kablam! warning: unused `futures::sink::Send` which must be used Aug 10 23:46:35.577 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Aug 10 23:46:35.577 INFO kablam! | Aug 10 23:46:35.577 INFO kablam! 100 | requester.send(LoopRequest::Internal(rel)); Aug 10 23:46:35.577 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:35.577 INFO kablam! | Aug 10 23:46:35.577 INFO kablam! = note: futures do nothing unless polled Aug 10 23:46:35.577 INFO kablam! Aug 10 23:46:35.611 INFO kablam! warning: unused `std::result::Result` which must be used Aug 10 23:46:35.611 INFO kablam! --> src/tokio/mqtt_loop.rs:571:17 Aug 10 23:46:35.611 INFO kablam! | Aug 10 23:46:35.611 INFO kablam! 571 | self.poll_queues(sourceitem); Aug 10 23:46:35.611 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:35.612 INFO kablam! | Aug 10 23:46:35.612 INFO kablam! = note: #[warn(unused_must_use)] on by default Aug 10 23:46:35.612 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Aug 10 23:46:35.612 INFO kablam! Aug 10 23:46:35.634 INFO kablam! warning: unused `std::result::Result` which must be used Aug 10 23:46:35.634 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:104:25 Aug 10 23:46:35.634 INFO kablam! | Aug 10 23:46:35.634 INFO kablam! 104 | / requester.unbounded_send(LoopRequest::Internal( Aug 10 23:46:35.634 INFO kablam! 105 | | MqttPacket::pub_ack_packet(*id), Aug 10 23:46:35.634 INFO kablam! 106 | | )); Aug 10 23:46:35.634 INFO kablam! | |___________________________^ Aug 10 23:46:35.634 INFO kablam! | Aug 10 23:46:35.634 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Aug 10 23:46:35.635 INFO kablam! Aug 10 23:46:35.635 INFO kablam! warning: unused `std::result::Result` which must be used Aug 10 23:46:35.635 INFO kablam! --> src/tokio/inbound_handlers/publish.rs:128:29 Aug 10 23:46:35.635 INFO kablam! | Aug 10 23:46:35.635 INFO kablam! 128 | / requester.unbounded_send( Aug 10 23:46:35.635 INFO kablam! 129 | | LoopRequest::Internal(MqttPacket::pub_rec_packet(*id)), Aug 10 23:46:35.635 INFO kablam! 130 | | ); Aug 10 23:46:35.635 INFO kablam! | |______________________________^ Aug 10 23:46:35.635 INFO kablam! | Aug 10 23:46:35.635 INFO kablam! = note: this `Result` may be an `Err` variant, which should be handled Aug 10 23:46:35.635 INFO kablam! Aug 10 23:46:35.637 INFO kablam! warning: unused `futures::sink::Send` which must be used Aug 10 23:46:35.637 INFO kablam! --> src/tokio/inbound_handlers/publish_recieve.rs:100:21 Aug 10 23:46:35.637 INFO kablam! | Aug 10 23:46:35.637 INFO kablam! 100 | requester.send(LoopRequest::Internal(rel)); Aug 10 23:46:35.637 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:35.637 INFO kablam! | Aug 10 23:46:35.638 INFO kablam! = note: futures do nothing unless polled Aug 10 23:46:35.638 INFO kablam! Aug 10 23:46:36.716 INFO kablam! warning: unused `#[macro_use]` import Aug 10 23:46:36.716 INFO kablam! --> examples/client.rs:1:1 Aug 10 23:46:36.717 INFO kablam! | Aug 10 23:46:36.717 INFO kablam! 1 | #[macro_use] Aug 10 23:46:36.717 INFO kablam! | ^^^^^^^^^^^^ Aug 10 23:46:36.717 INFO kablam! | Aug 10 23:46:36.717 INFO kablam! = note: #[warn(unused_imports)] on by default Aug 10 23:46:36.717 INFO kablam! Aug 10 23:46:36.717 INFO kablam! warning: unused import: `tokio_mqttc::persistence::*` Aug 10 23:46:36.717 INFO kablam! --> examples/client.rs:11:5 Aug 10 23:46:36.717 INFO kablam! | Aug 10 23:46:36.717 INFO kablam! 11 | use tokio_mqttc::persistence::*; Aug 10 23:46:36.717 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:36.717 INFO kablam! Aug 10 23:46:36.717 INFO kablam! warning: unused import: `tokio_mqttc::proto::*` Aug 10 23:46:36.717 INFO kablam! --> examples/client.rs:13:5 Aug 10 23:46:36.717 INFO kablam! | Aug 10 23:46:36.717 INFO kablam! 13 | use tokio_mqttc::proto::*; Aug 10 23:46:36.717 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:36.717 INFO kablam! Aug 10 23:46:36.717 INFO kablam! warning: unused import: `tokio_core::reactor::Handle` Aug 10 23:46:36.717 INFO kablam! --> examples/client.rs:41:5 Aug 10 23:46:36.717 INFO kablam! | Aug 10 23:46:36.717 INFO kablam! 41 | use tokio_core::reactor::Handle; Aug 10 23:46:36.717 INFO kablam! | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ Aug 10 23:46:36.717 INFO kablam! Aug 10 23:46:36.717 INFO kablam! warning: unused imports: `Sink`, `future` Aug 10 23:46:36.717 INFO kablam! --> examples/client.rs:45:15 Aug 10 23:46:36.717 INFO kablam! | Aug 10 23:46:36.717 INFO kablam! 45 | use futures::{future, Future, Stream, Sink}; Aug 10 23:46:36.717 INFO kablam! | ^^^^^^ ^^^^ Aug 10 23:46:36.717 INFO kablam! Aug 10 23:46:37.043 INFO kablam! warning: unused import: `Stream` Aug 10 23:46:37.043 INFO kablam! --> examples/client.rs:45:31 Aug 10 23:46:37.043 INFO kablam! | Aug 10 23:46:37.044 INFO kablam! 45 | use futures::{future, Future, Stream, Sink}; Aug 10 23:46:37.044 INFO kablam! | ^^^^^^ Aug 10 23:46:37.044 INFO kablam! Aug 10 23:46:37.204 INFO kablam! Finished dev [unoptimized + debuginfo] target(s) in 12.99s Aug 10 23:46:37.235 INFO kablam! su: No module specific data is present Aug 10 23:46:37.830 INFO running `"docker" "rm" "-f" "1d45c60257063bd3fc87c8d0c6c0cb02e8b4edb239493b8ac57172bba2dcd19b"` Aug 10 23:46:37.960 INFO blam! 1d45c60257063bd3fc87c8d0c6c0cb02e8b4edb239493b8ac57172bba2dcd19b