Sep 21 13:29:32.766 INFO checking amqpr-api-0.4.1 against try#f1a3f05968ed2a674e09b6efa4ad9df90816e2b6 for pr-54394
Sep 21 13:29:32.766 INFO running: cargo +f1a3f05968ed2a674e09b6efa4ad9df90816e2b6-alt check --frozen --all --all-targets
Sep 21 13:29:32.766 INFO running `"docker" "create" "-v" "/home/ec2-user/crater/./work/local/test-source/worker-4/pr-54394/try#f1a3f05968ed2a674e09b6efa4ad9df90816e2b6:/source:ro,Z" "-v" "/home/ec2-user/crater/./work/local/target-dirs/pr-54394/worker-4/try#f1a3f05968ed2a674e09b6efa4ad9df90816e2b6:/target:rw,Z" "-v" "/home/ec2-user/crater/./work/local/cargo-home:/cargo-home:ro,Z" "-v" "/home/ec2-user/crater/./work/local/rustup-home:/rustup-home:ro,Z" "-e" "USER_ID=1000" "-e" "CMD=cargo +f1a3f05968ed2a674e09b6efa4ad9df90816e2b6-alt check --frozen --all --all-targets" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-m" "1536M" "crater"`
Sep 21 13:29:32.968 INFO blam! 2134d970aaf5ae025f084243d3accd386f4cf25e7979d9316233e220d00a872e
Sep 21 13:29:32.970 INFO running `"docker" "start" "-a" "2134d970aaf5ae025f084243d3accd386f4cf25e7979d9316233e220d00a872e"`
Sep 21 13:29:33.891 INFO kablam! usermod: no changes
Sep 21 13:29:34.026 INFO kablam!     Checking amqpr-codec v0.3.2
Sep 21 13:29:34.026 INFO kablam!     Checking log4rs v0.7.0
Sep 21 13:29:35.339 INFO kablam!     Checking amqpr-api v0.4.1 (/source)
Sep 21 13:29:37.080 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec
Sep 21 13:29:37.080 INFO kablam!   --> src/lib.rs:57:18
Sep 21 13:29:37.080 INFO kablam!    |
Sep 21 13:29:37.080 INFO kablam! 57 | type RawSocket = tokio_io::codec::Framed<tokio_core::net::TcpStream, amqpr_codec::Codec>;
Sep 21 13:29:37.080 INFO kablam!    |                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
Sep 21 13:29:37.080 INFO kablam!    |
Sep 21 13:29:37.080 INFO kablam!    = note: #[warn(deprecated)] on by default
Sep 21 13:29:37.080 INFO kablam! 
Sep 21 13:29:37.154 INFO kablam! warning: the trait bound `S: futures::Sink` is not satisfied
Sep 21 13:29:37.154 INFO kablam!   --> src/exchange/declare.rs:10:32
Sep 21 13:29:37.154 INFO kablam!    |
Sep 21 13:29:37.154 INFO kablam! 10 | pub type ExchangeDeclared<S> = Send<S>;
Sep 21 13:29:37.154 INFO kablam!    |                                ^^^^^^^ the trait `futures::Sink` is not implemented for `S`
Sep 21 13:29:37.154 INFO kablam!    |
Sep 21 13:29:37.154 INFO kablam!    = note: #[warn(type_alias_missing_bounds)] on by default
Sep 21 13:29:37.154 INFO kablam!    = help: consider adding a `where S: futures::Sink` bound
Sep 21 13:29:37.154 INFO kablam!    = help: missing bounds in type aliases were previously allowed
Sep 21 13:29:37.154 INFO kablam!    = help: this is a hard error in Rust 2018
Sep 21 13:29:37.154 INFO kablam! 
Sep 21 13:29:37.154 INFO kablam! warning: the trait bound `S: futures::Sink` is not satisfied
Sep 21 13:29:37.154 INFO kablam!   --> src/queue/bind.rs:10:26
Sep 21 13:29:37.154 INFO kablam!    |
Sep 21 13:29:37.154 INFO kablam! 10 | pub type QueueBound<S> = Send<S>;
Sep 21 13:29:37.154 INFO kablam!    |                          ^^^^^^^ the trait `futures::Sink` is not implemented for `S`
Sep 21 13:29:37.154 INFO kablam!    |
Sep 21 13:29:37.154 INFO kablam!    = help: consider adding a `where S: futures::Sink` bound
Sep 21 13:29:37.154 INFO kablam!    = help: missing bounds in type aliases were previously allowed
Sep 21 13:29:37.154 INFO kablam!    = help: this is a hard error in Rust 2018
Sep 21 13:29:37.154 INFO kablam! 
Sep 21 13:29:37.154 INFO kablam! warning: the trait bound `S: futures::Sink` is not satisfied
Sep 21 13:29:37.154 INFO kablam!   --> src/basic/consume.rs:13:30
Sep 21 13:29:37.154 INFO kablam!    |
Sep 21 13:29:37.154 INFO kablam! 13 | pub type ConsumeStarted<S> = Send<S>;
Sep 21 13:29:37.154 INFO kablam!    |                              ^^^^^^^ the trait `futures::Sink` is not implemented for `S`
Sep 21 13:29:37.154 INFO kablam!    |
Sep 21 13:29:37.154 INFO kablam!    = help: consider adding a `where S: futures::Sink` bound
Sep 21 13:29:37.154 INFO kablam!    = help: missing bounds in type aliases were previously allowed
Sep 21 13:29:37.154 INFO kablam!    = help: this is a hard error in Rust 2018
Sep 21 13:29:37.154 INFO kablam! 
Sep 21 13:29:37.314 INFO kablam! warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead
Sep 21 13:29:37.314 INFO kablam!    --> src/handshake.rs:188:62
Sep 21 13:29:37.314 INFO kablam!     |
Sep 21 13:29:37.314 INFO kablam! 188 |                 ReceivingStart(Should::new(AmqpSocket(socket.framed(::amqpr_codec::Codec))))
Sep 21 13:29:37.314 INFO kablam!     |                                                              ^^^^^^
Sep 21 13:29:37.314 INFO kablam! 
Sep 21 13:29:40.950 INFO kablam! warning: use of deprecated item 'tokio_io::codec::Framed': Moved to tokio-codec
Sep 21 13:29:40.951 INFO kablam!   --> src/lib.rs:57:18
Sep 21 13:29:40.951 INFO kablam!    |
Sep 21 13:29:40.951 INFO kablam! 57 | type RawSocket = tokio_io::codec::Framed<tokio_core::net::TcpStream, amqpr_codec::Codec>;
Sep 21 13:29:40.952 INFO kablam!    |                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
Sep 21 13:29:40.952 INFO kablam!    |
Sep 21 13:29:40.952 INFO kablam!    = note: #[warn(deprecated)] on by default
Sep 21 13:29:40.952 INFO kablam! 
Sep 21 13:29:41.483 INFO kablam! warning: the trait bound `S: futures::Sink` is not satisfied
Sep 21 13:29:41.483 INFO kablam!   --> src/exchange/declare.rs:10:32
Sep 21 13:29:41.483 INFO kablam!    |
Sep 21 13:29:41.483 INFO kablam! 10 | pub type ExchangeDeclared<S> = Send<S>;
Sep 21 13:29:41.483 INFO kablam!    |                                ^^^^^^^ the trait `futures::Sink` is not implemented for `S`
Sep 21 13:29:41.483 INFO kablam!    |
Sep 21 13:29:41.483 INFO kablam!    = note: #[warn(type_alias_missing_bounds)] on by default
Sep 21 13:29:41.483 INFO kablam!    = help: consider adding a `where S: futures::Sink` bound
Sep 21 13:29:41.483 INFO kablam!    = help: missing bounds in type aliases were previously allowed
Sep 21 13:29:41.483 INFO kablam!    = help: this is a hard error in Rust 2018
Sep 21 13:29:41.483 INFO kablam! 
Sep 21 13:29:41.493 INFO kablam! warning: the trait bound `S: futures::Sink` is not satisfied
Sep 21 13:29:41.493 INFO kablam!   --> src/queue/bind.rs:10:26
Sep 21 13:29:41.493 INFO kablam!    |
Sep 21 13:29:41.493 INFO kablam! 10 | pub type QueueBound<S> = Send<S>;
Sep 21 13:29:41.493 INFO kablam!    |                          ^^^^^^^ the trait `futures::Sink` is not implemented for `S`
Sep 21 13:29:41.493 INFO kablam!    |
Sep 21 13:29:41.493 INFO kablam!    = help: consider adding a `where S: futures::Sink` bound
Sep 21 13:29:41.493 INFO kablam!    = help: missing bounds in type aliases were previously allowed
Sep 21 13:29:41.494 INFO kablam!    = help: this is a hard error in Rust 2018
Sep 21 13:29:41.494 INFO kablam! 
Sep 21 13:29:41.496 INFO kablam! warning: the trait bound `S: futures::Sink` is not satisfied
Sep 21 13:29:41.496 INFO kablam!   --> src/basic/consume.rs:13:30
Sep 21 13:29:41.496 INFO kablam!    |
Sep 21 13:29:41.496 INFO kablam! 13 | pub type ConsumeStarted<S> = Send<S>;
Sep 21 13:29:41.496 INFO kablam!    |                              ^^^^^^^ the trait `futures::Sink` is not implemented for `S`
Sep 21 13:29:41.510 INFO kablam!    |
Sep 21 13:29:41.510 INFO kablam!    = help: consider adding a `where S: futures::Sink` bound
Sep 21 13:29:41.510 INFO kablam!    = help: missing bounds in type aliases were previously allowed
Sep 21 13:29:41.511 INFO kablam!    = help: this is a hard error in Rust 2018
Sep 21 13:29:41.511 INFO kablam! 
Sep 21 13:29:42.178 INFO kablam! warning: use of deprecated item 'tokio_io::AsyncRead::framed': Use tokio_codec::Decoder::framed instead
Sep 21 13:29:42.179 INFO kablam!    --> src/handshake.rs:188:62
Sep 21 13:29:42.179 INFO kablam!     |
Sep 21 13:29:42.179 INFO kablam! 188 |                 ReceivingStart(Should::new(AmqpSocket(socket.framed(::amqpr_codec::Codec))))
Sep 21 13:29:42.180 INFO kablam!     |                                                              ^^^^^^
Sep 21 13:29:42.210 INFO kablam! 
Sep 21 13:29:52.866 INFO kablam! error[E0432]: unresolved import `amqpr_api::receive_delivered`
Sep 21 13:29:52.866 INFO kablam!   --> tests/consume.rs:15:47
Sep 21 13:29:52.866 INFO kablam!    |
Sep 21 13:29:52.866 INFO kablam! 15 |                 declare_queue, start_consume, receive_delivered};
Sep 21 13:29:52.866 INFO kablam!    |                                               ^^^^^^^^^^^^^^^^^ no `receive_delivered` in the root
Sep 21 13:29:52.866 INFO kablam! 
Sep 21 13:29:55.410 INFO kablam! error[E0308]: mismatched types
Sep 21 13:29:55.410 INFO kablam!   --> tests/consume.rs:40:41
Sep 21 13:29:55.410 INFO kablam!    |
Sep 21 13:29:55.410 INFO kablam! 40 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:55.410 INFO kablam!    |                                         ^^^^^^ expected u16, found struct `amqpr_api::AmqpSocket`
Sep 21 13:29:55.410 INFO kablam!    |
Sep 21 13:29:55.410 INFO kablam!    = note: expected type `u16`
Sep 21 13:29:55.410 INFO kablam!               found type `amqpr_api::AmqpSocket`
Sep 21 13:29:55.410 INFO kablam! 
Sep 21 13:29:55.410 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:55.410 INFO kablam!   --> tests/consume.rs:40:28
Sep 21 13:29:55.410 INFO kablam!    |
Sep 21 13:29:55.410 INFO kablam! 40 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:55.410 INFO kablam!    |                            ^^^^^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:55.410 INFO kablam!    |
Sep 21 13:29:55.410 INFO kablam!    = note: required by `amqpr_api::open_channel`
Sep 21 13:29:55.410 INFO kablam! 
Sep 21 13:29:55.410 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:55.410 INFO kablam!   --> tests/consume.rs:40:28
Sep 21 13:29:55.410 INFO kablam!    |
Sep 21 13:29:55.410 INFO kablam! 40 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:55.410 INFO kablam!    |                            ^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:55.410 INFO kablam!    |
Sep 21 13:29:55.410 INFO kablam!    = note: required by `amqpr_api::open_channel`
Sep 21 13:29:55.410 INFO kablam! 
Sep 21 13:29:55.410 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:55.410 INFO kablam!   --> tests/consume.rs:40:10
Sep 21 13:29:55.410 INFO kablam!    |
Sep 21 13:29:55.410 INFO kablam! 40 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:55.410 INFO kablam!    |          ^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:55.411 INFO kablam!    |
Sep 21 13:29:55.411 INFO kablam!    = note: required because of the requirements on the impl of `futures::Future` for `amqpr_api::channel::open::ChannelOpened<u16>`
Sep 21 13:29:55.411 INFO kablam! 
Sep 21 13:29:55.411 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:55.411 INFO kablam!   --> tests/consume.rs:40:10
Sep 21 13:29:55.411 INFO kablam!    |
Sep 21 13:29:55.411 INFO kablam! 40 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:55.411 INFO kablam!    |          ^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:55.411 INFO kablam!    |
Sep 21 13:29:55.411 INFO kablam!    = note: required because of the requirements on the impl of `futures::Future` for `amqpr_api::channel::open::ChannelOpened<u16>`
Sep 21 13:29:55.411 INFO kablam! 
Sep 21 13:29:55.426 INFO kablam! error[E0599]: no method named `and_then` found for type `futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/consume.rs:38:18: 38:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/consume.rs:39:19: 39:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/consume.rs:40:19: 40:66]>` in the current scope
Sep 21 13:29:55.426 INFO kablam!   --> tests/consume.rs:41:10
Sep 21 13:29:55.426 INFO kablam!    |
Sep 21 13:29:55.426 INFO kablam! 41 |         .and_then(|socket| {
Sep 21 13:29:55.426 INFO kablam!    |          ^^^^^^^^
Sep 21 13:29:55.426 INFO kablam!    |
Sep 21 13:29:55.426 INFO kablam!    = note: the method `and_then` exists but the following trait bounds were not satisfied:
Sep 21 13:29:55.426 INFO kablam!            `futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/consume.rs:38:18: 38:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/consume.rs:39:19: 39:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/consume.rs:40:19: 40:66]> : futures::Future`
Sep 21 13:29:55.426 INFO kablam!            `&mut futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/consume.rs:38:18: 38:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/consume.rs:39:19: 39:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/consume.rs:40:19: 40:66]> : futures::Future`
Sep 21 13:29:55.426 INFO kablam! 
Sep 21 13:29:55.426 INFO kablam! error[E0560]: struct `amqpr_api::exchange::declare::DeclareExchangeOption` has no field named `is_no_wait`
Sep 21 13:29:55.426 INFO kablam!   --> tests/consume.rs:49:17
Sep 21 13:29:55.426 INFO kablam!    |
Sep 21 13:29:55.426 INFO kablam! 49 |                 is_no_wait: false,
Sep 21 13:29:55.426 INFO kablam!    |                 ^^^^^^^^^^ `amqpr_api::exchange::declare::DeclareExchangeOption` does not have this field
Sep 21 13:29:55.426 INFO kablam!    |
Sep 21 13:29:55.426 INFO kablam!    = note: available fields are: `name`, `typ`, `is_passive`, `is_durable`, `is_auto_delete`, `is_internal`
Sep 21 13:29:55.426 INFO kablam! 
Sep 21 13:29:55.426 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:55.426 INFO kablam!   --> tests/consume.rs:51:13
Sep 21 13:29:55.426 INFO kablam!    |
Sep 21 13:29:55.426 INFO kablam! 51 |             declare_exchange(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:55.426 INFO kablam!    |             ^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:55.426 INFO kablam!    |
Sep 21 13:29:55.426 INFO kablam!    = note: required by `amqpr_api::declare_exchange`
Sep 21 13:29:55.426 INFO kablam! 
Sep 21 13:29:55.426 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:55.426 INFO kablam!   --> tests/consume.rs:51:13
Sep 21 13:29:55.426 INFO kablam!    |
Sep 21 13:29:55.426 INFO kablam! 51 |             declare_exchange(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:55.426 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:55.427 INFO kablam!    |
Sep 21 13:29:55.427 INFO kablam!    = note: required by `futures::sink::Send`
Sep 21 13:29:55.427 INFO kablam! 
Sep 21 13:29:55.430 INFO kablam! error[E0560]: struct `amqpr_api::queue::DeclareQueueOption` has no field named `is_no_wait`
Sep 21 13:29:55.430 INFO kablam!   --> tests/consume.rs:60:17
Sep 21 13:29:55.430 INFO kablam!    |
Sep 21 13:29:55.430 INFO kablam! 60 |                 is_no_wait: false,
Sep 21 13:29:55.430 INFO kablam!    |                 ^^^^^^^^^^ `amqpr_api::queue::DeclareQueueOption` does not have this field
Sep 21 13:29:55.430 INFO kablam!    |
Sep 21 13:29:55.430 INFO kablam!    = note: available fields are: `name`, `is_passive`, `is_durable`, `is_exclusive`, `is_auto_delete`
Sep 21 13:29:55.430 INFO kablam! 
Sep 21 13:29:55.430 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:55.430 INFO kablam!   --> tests/consume.rs:62:13
Sep 21 13:29:55.430 INFO kablam!    |
Sep 21 13:29:55.430 INFO kablam! 62 |             declare_queue(socket, LOCAL_CHANNEL_ID, option).map(|(_result, socket)| socket)
Sep 21 13:29:55.430 INFO kablam!    |             ^^^^^^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:55.430 INFO kablam!    |
Sep 21 13:29:55.430 INFO kablam!    = note: required by `amqpr_api::declare_queue`
Sep 21 13:29:55.430 INFO kablam! 
Sep 21 13:29:55.434 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:55.434 INFO kablam!   --> tests/consume.rs:62:13
Sep 21 13:29:55.434 INFO kablam!    |
Sep 21 13:29:55.434 INFO kablam! 62 |             declare_queue(socket, LOCAL_CHANNEL_ID, option).map(|(_result, socket)| socket)
Sep 21 13:29:55.434 INFO kablam!    |             ^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:55.434 INFO kablam!    |
Sep 21 13:29:55.446 INFO kablam!    = note: required by `amqpr_api::declare_queue`
Sep 21 13:29:55.446 INFO kablam! 
Sep 21 13:29:55.450 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:55.450 INFO kablam!   --> tests/consume.rs:62:13
Sep 21 13:29:55.450 INFO kablam!    |
Sep 21 13:29:55.450 INFO kablam! 62 |             declare_queue(socket, LOCAL_CHANNEL_ID, option).map(|(_result, socket)| socket)
Sep 21 13:29:55.450 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:55.450 INFO kablam!    |
Sep 21 13:29:55.450 INFO kablam!    = note: required by `amqpr_api::queue::declare::QueueDeclared`
Sep 21 13:29:55.450 INFO kablam! 
Sep 21 13:29:55.450 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:55.450 INFO kablam!   --> tests/consume.rs:62:13
Sep 21 13:29:55.450 INFO kablam!    |
Sep 21 13:29:55.450 INFO kablam! 62 |             declare_queue(socket, LOCAL_CHANNEL_ID, option).map(|(_result, socket)| socket)
Sep 21 13:29:55.450 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:55.450 INFO kablam!    |
Sep 21 13:29:55.450 INFO kablam!    = note: required by `amqpr_api::queue::declare::QueueDeclared`
Sep 21 13:29:55.450 INFO kablam! 
Sep 21 13:29:55.462 INFO kablam! error[E0599]: no method named `map` found for type `amqpr_api::queue::declare::QueueDeclared<u16, _>` in the current scope
Sep 21 13:29:55.462 INFO kablam!   --> tests/consume.rs:62:61
Sep 21 13:29:55.462 INFO kablam!    |
Sep 21 13:29:55.462 INFO kablam! 62 |             declare_queue(socket, LOCAL_CHANNEL_ID, option).map(|(_result, socket)| socket)
Sep 21 13:29:55.462 INFO kablam!    |                                                             ^^^
Sep 21 13:29:55.466 INFO kablam!    |
Sep 21 13:29:55.466 INFO kablam!    = note: the method `map` exists but the following trait bounds were not satisfied:
Sep 21 13:29:55.466 INFO kablam!            `amqpr_api::queue::declare::QueueDeclared<u16, _> : futures::Future`
Sep 21 13:29:55.466 INFO kablam!            `&mut amqpr_api::queue::declare::QueueDeclared<u16, _> : futures::Future`
Sep 21 13:29:55.466 INFO kablam!            `&mut amqpr_api::queue::declare::QueueDeclared<u16, _> : std::iter::Iterator`
Sep 21 13:29:55.466 INFO kablam! 
Sep 21 13:29:55.467 INFO kablam! error[E0560]: struct `amqpr_api::queue::BindQueueOption` has no field named `is_no_wait`
Sep 21 13:29:55.467 INFO kablam!   --> tests/consume.rs:69:17
Sep 21 13:29:55.467 INFO kablam!    |
Sep 21 13:29:55.467 INFO kablam! 69 |                 is_no_wait: false,
Sep 21 13:29:55.467 INFO kablam!    |                 ^^^^^^^^^^ `amqpr_api::queue::BindQueueOption` does not have this field
Sep 21 13:29:55.467 INFO kablam!    |
Sep 21 13:29:55.467 INFO kablam!    = note: available fields are: `queue`, `exchange`, `routing_key`
Sep 21 13:29:55.467 INFO kablam! 
Sep 21 13:29:55.478 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:55.478 INFO kablam!   --> tests/consume.rs:71:13
Sep 21 13:29:55.478 INFO kablam!    |
Sep 21 13:29:55.478 INFO kablam! 71 |             bind_queue(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:55.478 INFO kablam!    |             ^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:55.478 INFO kablam!    |
Sep 21 13:29:55.478 INFO kablam!    = note: required by `amqpr_api::bind_queue`
Sep 21 13:29:55.478 INFO kablam! 
Sep 21 13:29:55.478 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:55.478 INFO kablam!   --> tests/consume.rs:71:13
Sep 21 13:29:55.478 INFO kablam!    |
Sep 21 13:29:55.478 INFO kablam! 71 |             bind_queue(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:55.478 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:55.478 INFO kablam!    |
Sep 21 13:29:55.478 INFO kablam!    = note: required by `futures::sink::Send`
Sep 21 13:29:55.478 INFO kablam! 
Sep 21 13:29:55.478 INFO kablam! error[E0061]: this function takes 3 parameters but 4 parameters were supplied
Sep 21 13:29:55.478 INFO kablam!   --> tests/consume.rs:81:13
Sep 21 13:29:55.478 INFO kablam!    |
Sep 21 13:29:55.478 INFO kablam! 81 |             publish(socket, LOCAL_CHANNEL_ID, bytes, option)
Sep 21 13:29:55.478 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected 3 parameters
Sep 21 13:29:55.478 INFO kablam! 
Sep 21 13:29:55.478 INFO kablam! error[E0560]: struct `amqpr_api::basic::StartConsumeOption` has no field named `is_no_wait`
Sep 21 13:29:55.478 INFO kablam!   --> tests/consume.rs:90:17
Sep 21 13:29:55.478 INFO kablam!    |
Sep 21 13:29:55.478 INFO kablam! 90 |                 is_no_wait: false,
Sep 21 13:29:55.478 INFO kablam!    |                 ^^^^^^^^^^ `amqpr_api::basic::StartConsumeOption` does not have this field
Sep 21 13:29:55.478 INFO kablam!    |
Sep 21 13:29:55.478 INFO kablam!    = note: available fields are: `queue`, `consumer_tag`, `is_no_local`, `is_no_ack`, `is_exclusive`
Sep 21 13:29:55.478 INFO kablam! 
Sep 21 13:29:55.478 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:55.478 INFO kablam!   --> tests/consume.rs:92:13
Sep 21 13:29:55.478 INFO kablam!    |
Sep 21 13:29:55.478 INFO kablam! 92 |             start_consume(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:55.478 INFO kablam!    |             ^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:55.478 INFO kablam!    |
Sep 21 13:29:55.478 INFO kablam!    = note: required by `amqpr_api::start_consume`
Sep 21 13:29:55.479 INFO kablam! 
Sep 21 13:29:55.479 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:55.479 INFO kablam!   --> tests/consume.rs:92:13
Sep 21 13:29:55.479 INFO kablam!    |
Sep 21 13:29:55.479 INFO kablam! 92 |             start_consume(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:55.479 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:55.479 INFO kablam!    |
Sep 21 13:29:55.479 INFO kablam!    = note: required by `futures::sink::Send`
Sep 21 13:29:55.479 INFO kablam! 
Sep 21 13:29:55.586 INFO kablam! error: aborting due to 23 previous errors
Sep 21 13:29:55.586 INFO kablam! 
Sep 21 13:29:55.586 INFO kablam! Some errors occurred: E0061, E0277, E0308, E0432, E0560, E0599.
Sep 21 13:29:55.586 INFO kablam! For more information about an error, try `rustc --explain E0061`.
Sep 21 13:29:55.610 INFO kablam! error: Could not compile `amqpr-api`.
Sep 21 13:29:55.610 INFO kablam! warning: build failed, waiting for other jobs to finish...
Sep 21 13:29:56.598 INFO kablam! error[E0308]: mismatched types
Sep 21 13:29:56.599 INFO kablam!   --> tests/declare_queue.rs:34:41
Sep 21 13:29:56.599 INFO kablam!    |
Sep 21 13:29:56.599 INFO kablam! 34 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:56.599 INFO kablam!    |                                         ^^^^^^ expected u16, found struct `amqpr_api::AmqpSocket`
Sep 21 13:29:56.599 INFO kablam!    |
Sep 21 13:29:56.599 INFO kablam!    = note: expected type `u16`
Sep 21 13:29:56.599 INFO kablam!               found type `amqpr_api::AmqpSocket`
Sep 21 13:29:56.599 INFO kablam! 
Sep 21 13:29:56.599 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:56.599 INFO kablam!   --> tests/declare_queue.rs:34:28
Sep 21 13:29:56.599 INFO kablam!    |
Sep 21 13:29:56.599 INFO kablam! 34 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:56.599 INFO kablam!    |                            ^^^^^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:56.599 INFO kablam!    |
Sep 21 13:29:56.599 INFO kablam!    = note: required by `amqpr_api::open_channel`
Sep 21 13:29:56.599 INFO kablam! 
Sep 21 13:29:56.599 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:56.599 INFO kablam!   --> tests/declare_queue.rs:34:28
Sep 21 13:29:56.599 INFO kablam!    |
Sep 21 13:29:56.599 INFO kablam! 34 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:56.599 INFO kablam!    |                            ^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:56.599 INFO kablam!    |
Sep 21 13:29:56.599 INFO kablam!    = note: required by `amqpr_api::open_channel`
Sep 21 13:29:56.599 INFO kablam! 
Sep 21 13:29:56.599 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:56.599 INFO kablam!   --> tests/declare_queue.rs:34:10
Sep 21 13:29:56.599 INFO kablam!    |
Sep 21 13:29:56.599 INFO kablam! 34 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:56.599 INFO kablam!    |          ^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:56.599 INFO kablam!    |
Sep 21 13:29:56.599 INFO kablam!    = note: required because of the requirements on the impl of `futures::Future` for `amqpr_api::channel::open::ChannelOpened<u16>`
Sep 21 13:29:56.599 INFO kablam! 
Sep 21 13:29:56.599 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:56.599 INFO kablam!   --> tests/declare_queue.rs:34:10
Sep 21 13:29:56.599 INFO kablam!    |
Sep 21 13:29:56.599 INFO kablam! 34 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:56.599 INFO kablam!    |          ^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:56.599 INFO kablam!    |
Sep 21 13:29:56.599 INFO kablam!    = note: required because of the requirements on the impl of `futures::Future` for `amqpr_api::channel::open::ChannelOpened<u16>`
Sep 21 13:29:56.599 INFO kablam! 
Sep 21 13:29:56.634 INFO kablam! error[E0599]: no method named `and_then` found for type `futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/declare_queue.rs:32:18: 32:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/declare_queue.rs:33:19: 33:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/declare_queue.rs:34:19: 34:66]>` in the current scope
Sep 21 13:29:56.634 INFO kablam!   --> tests/declare_queue.rs:35:10
Sep 21 13:29:56.634 INFO kablam!    |
Sep 21 13:29:56.634 INFO kablam! 35 |         .and_then(|socket| {
Sep 21 13:29:56.634 INFO kablam!    |          ^^^^^^^^
Sep 21 13:29:56.634 INFO kablam!    |
Sep 21 13:29:56.634 INFO kablam!    = note: the method `and_then` exists but the following trait bounds were not satisfied:
Sep 21 13:29:56.634 INFO kablam!            `futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/declare_queue.rs:32:18: 32:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/declare_queue.rs:33:19: 33:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/declare_queue.rs:34:19: 34:66]> : futures::Future`
Sep 21 13:29:56.634 INFO kablam!            `&mut futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/declare_queue.rs:32:18: 32:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/declare_queue.rs:33:19: 33:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/declare_queue.rs:34:19: 34:66]> : futures::Future`
Sep 21 13:29:56.650 INFO kablam! 
Sep 21 13:29:56.651 INFO kablam! error[E0560]: struct `amqpr_api::queue::DeclareQueueOption` has no field named `is_no_wait`
Sep 21 13:29:56.651 INFO kablam!   --> tests/declare_queue.rs:42:17
Sep 21 13:29:56.651 INFO kablam!    |
Sep 21 13:29:56.652 INFO kablam! 42 |                 is_no_wait: false,
Sep 21 13:29:56.652 INFO kablam!    |                 ^^^^^^^^^^ `amqpr_api::queue::DeclareQueueOption` does not have this field
Sep 21 13:29:56.652 INFO kablam!    |
Sep 21 13:29:56.653 INFO kablam!    = note: available fields are: `name`, `is_passive`, `is_durable`, `is_exclusive`, `is_auto_delete`
Sep 21 13:29:56.653 INFO kablam! 
Sep 21 13:29:56.654 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:56.654 INFO kablam!   --> tests/declare_queue.rs:44:13
Sep 21 13:29:56.655 INFO kablam!    |
Sep 21 13:29:56.655 INFO kablam! 44 |             declare_queue(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:56.655 INFO kablam!    |             ^^^^^^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:56.656 INFO kablam!    |
Sep 21 13:29:56.656 INFO kablam!    = note: required by `amqpr_api::declare_queue`
Sep 21 13:29:56.656 INFO kablam! 
Sep 21 13:29:56.657 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:56.657 INFO kablam!   --> tests/declare_queue.rs:44:13
Sep 21 13:29:56.658 INFO kablam!    |
Sep 21 13:29:56.658 INFO kablam! 44 |             declare_queue(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:56.658 INFO kablam!    |             ^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:56.659 INFO kablam!    |
Sep 21 13:29:56.659 INFO kablam!    = note: required by `amqpr_api::declare_queue`
Sep 21 13:29:56.659 INFO kablam! 
Sep 21 13:29:56.660 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:56.660 INFO kablam!   --> tests/declare_queue.rs:44:13
Sep 21 13:29:56.661 INFO kablam!    |
Sep 21 13:29:56.661 INFO kablam! 44 |             declare_queue(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:56.661 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:56.662 INFO kablam!    |
Sep 21 13:29:56.662 INFO kablam!    = note: required by `amqpr_api::queue::declare::QueueDeclared`
Sep 21 13:29:56.662 INFO kablam! 
Sep 21 13:29:56.663 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:56.663 INFO kablam!   --> tests/declare_queue.rs:44:13
Sep 21 13:29:56.664 INFO kablam!    |
Sep 21 13:29:56.664 INFO kablam! 44 |             declare_queue(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:56.665 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:56.665 INFO kablam!    |
Sep 21 13:29:56.666 INFO kablam!    = note: required by `amqpr_api::queue::declare::QueueDeclared`
Sep 21 13:29:56.666 INFO kablam! 
Sep 21 13:29:56.774 INFO kablam! error: aborting due to 11 previous errors
Sep 21 13:29:56.787 INFO kablam! 
Sep 21 13:29:56.787 INFO kablam! Some errors occurred: E0277, E0308, E0560, E0599.
Sep 21 13:29:56.794 INFO kablam! For more information about an error, try `rustc --explain E0277`.
Sep 21 13:29:56.855 INFO kablam! error: Could not compile `amqpr-api`.
Sep 21 13:29:56.855 INFO kablam! warning: build failed, waiting for other jobs to finish...
Sep 21 13:29:57.350 INFO kablam! error[E0308]: mismatched types
Sep 21 13:29:57.350 INFO kablam!   --> tests/declare_exchange.rs:35:41
Sep 21 13:29:57.350 INFO kablam!    |
Sep 21 13:29:57.350 INFO kablam! 35 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:57.350 INFO kablam!    |                                         ^^^^^^ expected u16, found struct `amqpr_api::AmqpSocket`
Sep 21 13:29:57.350 INFO kablam!    |
Sep 21 13:29:57.350 INFO kablam!    = note: expected type `u16`
Sep 21 13:29:57.350 INFO kablam!               found type `amqpr_api::AmqpSocket`
Sep 21 13:29:57.350 INFO kablam! 
Sep 21 13:29:57.362 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:57.362 INFO kablam!   --> tests/declare_exchange.rs:35:28
Sep 21 13:29:57.362 INFO kablam!    |
Sep 21 13:29:57.362 INFO kablam! 35 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:57.362 INFO kablam!    |                            ^^^^^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:57.362 INFO kablam!    |
Sep 21 13:29:57.362 INFO kablam!    = note: required by `amqpr_api::open_channel`
Sep 21 13:29:57.362 INFO kablam! 
Sep 21 13:29:57.362 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:57.362 INFO kablam!   --> tests/declare_exchange.rs:35:28
Sep 21 13:29:57.362 INFO kablam!    |
Sep 21 13:29:57.362 INFO kablam! 35 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:57.362 INFO kablam!    |                            ^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:57.362 INFO kablam!    |
Sep 21 13:29:57.362 INFO kablam!    = note: required by `amqpr_api::open_channel`
Sep 21 13:29:57.362 INFO kablam! 
Sep 21 13:29:57.362 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:57.362 INFO kablam!   --> tests/declare_exchange.rs:35:10
Sep 21 13:29:57.362 INFO kablam!    |
Sep 21 13:29:57.362 INFO kablam! 35 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:57.362 INFO kablam!    |          ^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:57.362 INFO kablam!    |
Sep 21 13:29:57.362 INFO kablam!    = note: required because of the requirements on the impl of `futures::Future` for `amqpr_api::channel::open::ChannelOpened<u16>`
Sep 21 13:29:57.362 INFO kablam! 
Sep 21 13:29:57.362 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:57.362 INFO kablam!   --> tests/declare_exchange.rs:35:10
Sep 21 13:29:57.362 INFO kablam!    |
Sep 21 13:29:57.362 INFO kablam! 35 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:57.362 INFO kablam!    |          ^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:57.362 INFO kablam!    |
Sep 21 13:29:57.362 INFO kablam!    = note: required because of the requirements on the impl of `futures::Future` for `amqpr_api::channel::open::ChannelOpened<u16>`
Sep 21 13:29:57.362 INFO kablam! 
Sep 21 13:29:57.362 INFO kablam! error[E0599]: no method named `and_then` found for type `futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/declare_exchange.rs:33:18: 33:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/declare_exchange.rs:34:19: 34:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/declare_exchange.rs:35:19: 35:66]>` in the current scope
Sep 21 13:29:57.362 INFO kablam!   --> tests/declare_exchange.rs:36:10
Sep 21 13:29:57.362 INFO kablam!    |
Sep 21 13:29:57.362 INFO kablam! 36 |         .and_then(|socket| {
Sep 21 13:29:57.362 INFO kablam!    |          ^^^^^^^^
Sep 21 13:29:57.362 INFO kablam!    |
Sep 21 13:29:57.363 INFO kablam!    = note: the method `and_then` exists but the following trait bounds were not satisfied:
Sep 21 13:29:57.363 INFO kablam!            `futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/declare_exchange.rs:33:18: 33:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/declare_exchange.rs:34:19: 34:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/declare_exchange.rs:35:19: 35:66]> : futures::Future`
Sep 21 13:29:57.363 INFO kablam!            `&mut futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/declare_exchange.rs:33:18: 33:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/declare_exchange.rs:34:19: 34:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/declare_exchange.rs:35:19: 35:66]> : futures::Future`
Sep 21 13:29:57.363 INFO kablam! 
Sep 21 13:29:57.366 INFO kablam! error[E0560]: struct `amqpr_api::exchange::declare::DeclareExchangeOption` has no field named `is_no_wait`
Sep 21 13:29:57.366 INFO kablam!   --> tests/declare_exchange.rs:44:17
Sep 21 13:29:57.366 INFO kablam!    |
Sep 21 13:29:57.366 INFO kablam! 44 |                 is_no_wait: false,
Sep 21 13:29:57.366 INFO kablam!    |                 ^^^^^^^^^^ `amqpr_api::exchange::declare::DeclareExchangeOption` does not have this field
Sep 21 13:29:57.366 INFO kablam!    |
Sep 21 13:29:57.366 INFO kablam!    = note: available fields are: `name`, `typ`, `is_passive`, `is_durable`, `is_auto_delete`, `is_internal`
Sep 21 13:29:57.366 INFO kablam! 
Sep 21 13:29:57.366 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:57.366 INFO kablam!   --> tests/declare_exchange.rs:46:13
Sep 21 13:29:57.366 INFO kablam!    |
Sep 21 13:29:57.366 INFO kablam! 46 |             declare_exchange(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:57.366 INFO kablam!    |             ^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:57.366 INFO kablam!    |
Sep 21 13:29:57.366 INFO kablam!    = note: required by `amqpr_api::declare_exchange`
Sep 21 13:29:57.366 INFO kablam! 
Sep 21 13:29:57.366 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:57.366 INFO kablam!   --> tests/declare_exchange.rs:46:13
Sep 21 13:29:57.366 INFO kablam!    |
Sep 21 13:29:57.366 INFO kablam! 46 |             declare_exchange(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:57.366 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:57.366 INFO kablam!    |
Sep 21 13:29:57.366 INFO kablam!    = note: required by `futures::sink::Send`
Sep 21 13:29:57.366 INFO kablam! 
Sep 21 13:29:57.394 INFO kablam! error: aborting due to 9 previous errors
Sep 21 13:29:57.394 INFO kablam! 
Sep 21 13:29:57.394 INFO kablam! Some errors occurred: E0277, E0308, E0560, E0599.
Sep 21 13:29:57.394 INFO kablam! For more information about an error, try `rustc --explain E0277`.
Sep 21 13:29:57.402 INFO kablam! error[E0308]: mismatched types
Sep 21 13:29:57.402 INFO kablam!   --> tests/publish.rs:38:41
Sep 21 13:29:57.402 INFO kablam!    |
Sep 21 13:29:57.402 INFO kablam! 38 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:57.402 INFO kablam!    |                                         ^^^^^^ expected u16, found struct `amqpr_api::AmqpSocket`
Sep 21 13:29:57.402 INFO kablam!    |
Sep 21 13:29:57.402 INFO kablam!    = note: expected type `u16`
Sep 21 13:29:57.402 INFO kablam!               found type `amqpr_api::AmqpSocket`
Sep 21 13:29:57.402 INFO kablam! 
Sep 21 13:29:57.411 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:57.411 INFO kablam!   --> tests/publish.rs:38:28
Sep 21 13:29:57.411 INFO kablam!    |
Sep 21 13:29:57.411 INFO kablam! 38 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:57.411 INFO kablam!    |                            ^^^^^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:57.411 INFO kablam!    |
Sep 21 13:29:57.411 INFO kablam!    = note: required by `amqpr_api::open_channel`
Sep 21 13:29:57.411 INFO kablam! 
Sep 21 13:29:57.411 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:57.411 INFO kablam!   --> tests/publish.rs:38:28
Sep 21 13:29:57.411 INFO kablam!    |
Sep 21 13:29:57.411 INFO kablam! 38 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:57.411 INFO kablam!    |                            ^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:57.411 INFO kablam!    |
Sep 21 13:29:57.411 INFO kablam!    = note: required by `amqpr_api::open_channel`
Sep 21 13:29:57.411 INFO kablam! 
Sep 21 13:29:57.411 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:57.411 INFO kablam!   --> tests/publish.rs:38:10
Sep 21 13:29:57.411 INFO kablam!    |
Sep 21 13:29:57.411 INFO kablam! 38 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:57.411 INFO kablam!    |          ^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:57.411 INFO kablam!    |
Sep 21 13:29:57.411 INFO kablam!    = note: required because of the requirements on the impl of `futures::Future` for `amqpr_api::channel::open::ChannelOpened<u16>`
Sep 21 13:29:57.411 INFO kablam! 
Sep 21 13:29:57.411 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:57.411 INFO kablam!   --> tests/publish.rs:38:10
Sep 21 13:29:57.411 INFO kablam!    |
Sep 21 13:29:57.411 INFO kablam! 38 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:57.411 INFO kablam!    |          ^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:57.411 INFO kablam!    |
Sep 21 13:29:57.411 INFO kablam!    = note: required because of the requirements on the impl of `futures::Future` for `amqpr_api::channel::open::ChannelOpened<u16>`
Sep 21 13:29:57.411 INFO kablam! 
Sep 21 13:29:57.424 INFO kablam! error: Could not compile `amqpr-api`.
Sep 21 13:29:57.424 INFO kablam! warning: build failed, waiting for other jobs to finish...
Sep 21 13:29:57.443 INFO kablam! error[E0599]: no method named `and_then` found for type `futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/publish.rs:36:18: 36:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/publish.rs:37:19: 37:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/publish.rs:38:19: 38:66]>` in the current scope
Sep 21 13:29:57.443 INFO kablam!   --> tests/publish.rs:39:10
Sep 21 13:29:57.443 INFO kablam!    |
Sep 21 13:29:57.443 INFO kablam! 39 |         .and_then(|socket| {
Sep 21 13:29:57.443 INFO kablam!    |          ^^^^^^^^
Sep 21 13:29:57.443 INFO kablam!    |
Sep 21 13:29:57.443 INFO kablam!    = note: the method `and_then` exists but the following trait bounds were not satisfied:
Sep 21 13:29:57.443 INFO kablam!            `futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/publish.rs:36:18: 36:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/publish.rs:37:19: 37:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/publish.rs:38:19: 38:66]> : futures::Future`
Sep 21 13:29:57.443 INFO kablam!            `&mut futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/publish.rs:36:18: 36:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/publish.rs:37:19: 37:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/publish.rs:38:19: 38:66]> : futures::Future`
Sep 21 13:29:57.443 INFO kablam! 
Sep 21 13:29:57.443 INFO kablam! error[E0560]: struct `amqpr_api::exchange::declare::DeclareExchangeOption` has no field named `is_no_wait`
Sep 21 13:29:57.443 INFO kablam!   --> tests/publish.rs:47:17
Sep 21 13:29:57.443 INFO kablam!    |
Sep 21 13:29:57.443 INFO kablam! 47 |                 is_no_wait: false,
Sep 21 13:29:57.443 INFO kablam!    |                 ^^^^^^^^^^ `amqpr_api::exchange::declare::DeclareExchangeOption` does not have this field
Sep 21 13:29:57.443 INFO kablam!    |
Sep 21 13:29:57.443 INFO kablam!    = note: available fields are: `name`, `typ`, `is_passive`, `is_durable`, `is_auto_delete`, `is_internal`
Sep 21 13:29:57.443 INFO kablam! 
Sep 21 13:29:57.443 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:57.443 INFO kablam!   --> tests/publish.rs:49:13
Sep 21 13:29:57.443 INFO kablam!    |
Sep 21 13:29:57.443 INFO kablam! 49 |             declare_exchange(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:57.443 INFO kablam!    |             ^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:57.443 INFO kablam!    |
Sep 21 13:29:57.443 INFO kablam!    = note: required by `amqpr_api::declare_exchange`
Sep 21 13:29:57.443 INFO kablam! 
Sep 21 13:29:57.443 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:57.443 INFO kablam!   --> tests/publish.rs:49:13
Sep 21 13:29:57.443 INFO kablam!    |
Sep 21 13:29:57.443 INFO kablam! 49 |             declare_exchange(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:57.443 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:57.443 INFO kablam!    |
Sep 21 13:29:57.443 INFO kablam!    = note: required by `futures::sink::Send`
Sep 21 13:29:57.443 INFO kablam! 
Sep 21 13:29:57.443 INFO kablam! error[E0061]: this function takes 3 parameters but 4 parameters were supplied
Sep 21 13:29:57.443 INFO kablam!   --> tests/publish.rs:59:13
Sep 21 13:29:57.443 INFO kablam!    |
Sep 21 13:29:57.443 INFO kablam! 59 |             publish(socket, LOCAL_CHANNEL_ID, bytes, option)
Sep 21 13:29:57.443 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected 3 parameters
Sep 21 13:29:57.443 INFO kablam! 
Sep 21 13:29:57.503 INFO kablam! error: aborting due to 10 previous errors
Sep 21 13:29:57.503 INFO kablam! 
Sep 21 13:29:57.503 INFO kablam! Some errors occurred: E0061, E0277, E0308, E0560, E0599.
Sep 21 13:29:57.503 INFO kablam! For more information about an error, try `rustc --explain E0061`.
Sep 21 13:29:57.550 INFO kablam! error: Could not compile `amqpr-api`.
Sep 21 13:29:57.550 INFO kablam! warning: build failed, waiting for other jobs to finish...
Sep 21 13:29:58.169 INFO kablam! error[E0308]: mismatched types
Sep 21 13:29:58.169 INFO kablam!   --> tests/bind_queue.rs:37:41
Sep 21 13:29:58.169 INFO kablam!    |
Sep 21 13:29:58.169 INFO kablam! 37 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:58.170 INFO kablam!    |                                         ^^^^^^ expected u16, found struct `amqpr_api::AmqpSocket`
Sep 21 13:29:58.170 INFO kablam!    |
Sep 21 13:29:58.170 INFO kablam!    = note: expected type `u16`
Sep 21 13:29:58.170 INFO kablam!               found type `amqpr_api::AmqpSocket`
Sep 21 13:29:58.170 INFO kablam! 
Sep 21 13:29:58.170 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:58.170 INFO kablam!   --> tests/bind_queue.rs:37:28
Sep 21 13:29:58.170 INFO kablam!    |
Sep 21 13:29:58.170 INFO kablam! 37 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:58.170 INFO kablam!    |                            ^^^^^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:58.170 INFO kablam!    |
Sep 21 13:29:58.170 INFO kablam!    = note: required by `amqpr_api::open_channel`
Sep 21 13:29:58.170 INFO kablam! 
Sep 21 13:29:58.170 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:58.170 INFO kablam!   --> tests/bind_queue.rs:37:28
Sep 21 13:29:58.170 INFO kablam!    |
Sep 21 13:29:58.170 INFO kablam! 37 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:58.170 INFO kablam!    |                            ^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:58.170 INFO kablam!    |
Sep 21 13:29:58.170 INFO kablam!    = note: required by `amqpr_api::open_channel`
Sep 21 13:29:58.170 INFO kablam! 
Sep 21 13:29:58.171 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:58.171 INFO kablam!   --> tests/bind_queue.rs:37:10
Sep 21 13:29:58.171 INFO kablam!    |
Sep 21 13:29:58.171 INFO kablam! 37 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:58.171 INFO kablam!    |          ^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:58.171 INFO kablam!    |
Sep 21 13:29:58.171 INFO kablam!    = note: required because of the requirements on the impl of `futures::Future` for `amqpr_api::channel::open::ChannelOpened<u16>`
Sep 21 13:29:58.171 INFO kablam! 
Sep 21 13:29:58.171 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:58.171 INFO kablam!   --> tests/bind_queue.rs:37:10
Sep 21 13:29:58.171 INFO kablam!    |
Sep 21 13:29:58.171 INFO kablam! 37 |         .and_then(|socket| open_channel(socket, LOCAL_CHANNEL_ID))
Sep 21 13:29:58.171 INFO kablam!    |          ^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:58.171 INFO kablam!    |
Sep 21 13:29:58.171 INFO kablam!    = note: required because of the requirements on the impl of `futures::Future` for `amqpr_api::channel::open::ChannelOpened<u16>`
Sep 21 13:29:58.171 INFO kablam! 
Sep 21 13:29:58.174 INFO kablam! error[E0599]: no method named `and_then` found for type `futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/bind_queue.rs:35:18: 35:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/bind_queue.rs:36:19: 36:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/bind_queue.rs:37:19: 37:66]>` in the current scope
Sep 21 13:29:58.174 INFO kablam!   --> tests/bind_queue.rs:38:10
Sep 21 13:29:58.174 INFO kablam!    |
Sep 21 13:29:58.174 INFO kablam! 38 |         .and_then(|socket| {
Sep 21 13:29:58.174 INFO kablam!    |          ^^^^^^^^
Sep 21 13:29:58.174 INFO kablam!    |
Sep 21 13:29:58.174 INFO kablam!    = note: the method `and_then` exists but the following trait bounds were not satisfied:
Sep 21 13:29:58.174 INFO kablam!            `futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/bind_queue.rs:35:18: 35:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/bind_queue.rs:36:19: 36:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/bind_queue.rs:37:19: 37:66]> : futures::Future`
Sep 21 13:29:58.174 INFO kablam!            `&mut futures::AndThen<futures::AndThen<futures::MapErr<tokio_core::net::TcpStreamNew, [closure@tests/bind_queue.rs:35:18: 35:36]>, amqpr_api::handshake::Handshaking<amqpr_api::handshake::SimpleHandshaker>, [closure@tests/bind_queue.rs:36:19: 36:63 handshaker:_]>, amqpr_api::channel::open::ChannelOpened<u16>, [closure@tests/bind_queue.rs:37:19: 37:66]> : futures::Future`
Sep 21 13:29:58.174 INFO kablam! 
Sep 21 13:29:58.175 INFO kablam! error[E0560]: struct `amqpr_api::exchange::declare::DeclareExchangeOption` has no field named `is_no_wait`
Sep 21 13:29:58.175 INFO kablam!   --> tests/bind_queue.rs:46:17
Sep 21 13:29:58.175 INFO kablam!    |
Sep 21 13:29:58.175 INFO kablam! 46 |                 is_no_wait: false,
Sep 21 13:29:58.175 INFO kablam!    |                 ^^^^^^^^^^ `amqpr_api::exchange::declare::DeclareExchangeOption` does not have this field
Sep 21 13:29:58.175 INFO kablam!    |
Sep 21 13:29:58.175 INFO kablam!    = note: available fields are: `name`, `typ`, `is_passive`, `is_durable`, `is_auto_delete`, `is_internal`
Sep 21 13:29:58.175 INFO kablam! 
Sep 21 13:29:58.175 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:58.175 INFO kablam!   --> tests/bind_queue.rs:48:13
Sep 21 13:29:58.175 INFO kablam!    |
Sep 21 13:29:58.175 INFO kablam! 48 |             declare_exchange(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:58.175 INFO kablam!    |             ^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:58.175 INFO kablam!    |
Sep 21 13:29:58.175 INFO kablam!    = note: required by `amqpr_api::declare_exchange`
Sep 21 13:29:58.175 INFO kablam! 
Sep 21 13:29:58.175 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:58.175 INFO kablam!   --> tests/bind_queue.rs:48:13
Sep 21 13:29:58.175 INFO kablam!    |
Sep 21 13:29:58.175 INFO kablam! 48 |             declare_exchange(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:58.175 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:58.175 INFO kablam!    |
Sep 21 13:29:58.175 INFO kablam!    = note: required by `futures::sink::Send`
Sep 21 13:29:58.175 INFO kablam! 
Sep 21 13:29:58.175 INFO kablam! error[E0560]: struct `amqpr_api::queue::DeclareQueueOption` has no field named `is_no_wait`
Sep 21 13:29:58.175 INFO kablam!   --> tests/bind_queue.rs:57:17
Sep 21 13:29:58.175 INFO kablam!    |
Sep 21 13:29:58.175 INFO kablam! 57 |                 is_no_wait: false,
Sep 21 13:29:58.175 INFO kablam!    |                 ^^^^^^^^^^ `amqpr_api::queue::DeclareQueueOption` does not have this field
Sep 21 13:29:58.175 INFO kablam!    |
Sep 21 13:29:58.175 INFO kablam!    = note: available fields are: `name`, `is_passive`, `is_durable`, `is_exclusive`, `is_auto_delete`
Sep 21 13:29:58.175 INFO kablam! 
Sep 21 13:29:58.176 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:58.176 INFO kablam!   --> tests/bind_queue.rs:59:13
Sep 21 13:29:58.176 INFO kablam!    |
Sep 21 13:29:58.176 INFO kablam! 59 |             declare_queue(socket, LOCAL_CHANNEL_ID, option).map(|(_result, socket)| socket)
Sep 21 13:29:58.176 INFO kablam!    |             ^^^^^^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:58.176 INFO kablam!    |
Sep 21 13:29:58.176 INFO kablam!    = note: required by `amqpr_api::declare_queue`
Sep 21 13:29:58.176 INFO kablam! 
Sep 21 13:29:58.176 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:58.176 INFO kablam!   --> tests/bind_queue.rs:59:13
Sep 21 13:29:58.176 INFO kablam!    |
Sep 21 13:29:58.176 INFO kablam! 59 |             declare_queue(socket, LOCAL_CHANNEL_ID, option).map(|(_result, socket)| socket)
Sep 21 13:29:58.176 INFO kablam!    |             ^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:58.176 INFO kablam!    |
Sep 21 13:29:58.176 INFO kablam!    = note: required by `amqpr_api::declare_queue`
Sep 21 13:29:58.176 INFO kablam! 
Sep 21 13:29:58.176 INFO kablam! error[E0277]: the trait bound `u16: futures::Stream` is not satisfied
Sep 21 13:29:58.177 INFO kablam!   --> tests/bind_queue.rs:59:13
Sep 21 13:29:58.177 INFO kablam!    |
Sep 21 13:29:58.177 INFO kablam! 59 |             declare_queue(socket, LOCAL_CHANNEL_ID, option).map(|(_result, socket)| socket)
Sep 21 13:29:58.177 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Stream` is not implemented for `u16`
Sep 21 13:29:58.177 INFO kablam!    |
Sep 21 13:29:58.177 INFO kablam!    = note: required by `amqpr_api::queue::declare::QueueDeclared`
Sep 21 13:29:58.177 INFO kablam! 
Sep 21 13:29:58.177 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:58.177 INFO kablam!   --> tests/bind_queue.rs:59:13
Sep 21 13:29:58.177 INFO kablam!    |
Sep 21 13:29:58.177 INFO kablam! 59 |             declare_queue(socket, LOCAL_CHANNEL_ID, option).map(|(_result, socket)| socket)
Sep 21 13:29:58.177 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:58.177 INFO kablam!    |
Sep 21 13:29:58.177 INFO kablam!    = note: required by `amqpr_api::queue::declare::QueueDeclared`
Sep 21 13:29:58.177 INFO kablam! 
Sep 21 13:29:58.178 INFO kablam! error[E0599]: no method named `map` found for type `amqpr_api::queue::declare::QueueDeclared<u16, _>` in the current scope
Sep 21 13:29:58.178 INFO kablam!   --> tests/bind_queue.rs:59:61
Sep 21 13:29:58.178 INFO kablam!    |
Sep 21 13:29:58.178 INFO kablam! 59 |             declare_queue(socket, LOCAL_CHANNEL_ID, option).map(|(_result, socket)| socket)
Sep 21 13:29:58.178 INFO kablam!    |                                                             ^^^
Sep 21 13:29:58.178 INFO kablam!    |
Sep 21 13:29:58.178 INFO kablam!    = note: the method `map` exists but the following trait bounds were not satisfied:
Sep 21 13:29:58.178 INFO kablam!            `amqpr_api::queue::declare::QueueDeclared<u16, _> : futures::Future`
Sep 21 13:29:58.178 INFO kablam!            `&mut amqpr_api::queue::declare::QueueDeclared<u16, _> : futures::Future`
Sep 21 13:29:58.178 INFO kablam!            `&mut amqpr_api::queue::declare::QueueDeclared<u16, _> : std::iter::Iterator`
Sep 21 13:29:58.178 INFO kablam! 
Sep 21 13:29:58.178 INFO kablam! error[E0560]: struct `amqpr_api::queue::BindQueueOption` has no field named `is_no_wait`
Sep 21 13:29:58.178 INFO kablam!   --> tests/bind_queue.rs:66:17
Sep 21 13:29:58.178 INFO kablam!    |
Sep 21 13:29:58.178 INFO kablam! 66 |                 is_no_wait: false,
Sep 21 13:29:58.178 INFO kablam!    |                 ^^^^^^^^^^ `amqpr_api::queue::BindQueueOption` does not have this field
Sep 21 13:29:58.178 INFO kablam!    |
Sep 21 13:29:58.178 INFO kablam!    = note: available fields are: `queue`, `exchange`, `routing_key`
Sep 21 13:29:58.178 INFO kablam! 
Sep 21 13:29:58.178 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:58.178 INFO kablam!   --> tests/bind_queue.rs:68:13
Sep 21 13:29:58.178 INFO kablam!    |
Sep 21 13:29:58.178 INFO kablam! 68 |             bind_queue(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:58.178 INFO kablam!    |             ^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:58.178 INFO kablam!    |
Sep 21 13:29:58.179 INFO kablam!    = note: required by `amqpr_api::bind_queue`
Sep 21 13:29:58.179 INFO kablam! 
Sep 21 13:29:58.179 INFO kablam! error[E0277]: the trait bound `u16: futures::Sink` is not satisfied
Sep 21 13:29:58.179 INFO kablam!   --> tests/bind_queue.rs:68:13
Sep 21 13:29:58.179 INFO kablam!    |
Sep 21 13:29:58.179 INFO kablam! 68 |             bind_queue(socket, LOCAL_CHANNEL_ID, option)
Sep 21 13:29:58.179 INFO kablam!    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `futures::Sink` is not implemented for `u16`
Sep 21 13:29:58.179 INFO kablam!    |
Sep 21 13:29:58.179 INFO kablam!    = note: required by `futures::sink::Send`
Sep 21 13:29:58.179 INFO kablam! 
Sep 21 13:29:58.191 INFO kablam! error: aborting due to 18 previous errors
Sep 21 13:29:58.191 INFO kablam! 
Sep 21 13:29:58.191 INFO kablam! Some errors occurred: E0277, E0308, E0560, E0599.
Sep 21 13:29:58.191 INFO kablam! For more information about an error, try `rustc --explain E0277`.
Sep 21 13:29:58.216 INFO kablam! error: Could not compile `amqpr-api`.
Sep 21 13:29:58.216 INFO kablam! 
Sep 21 13:29:58.216 INFO kablam! To learn more, run the command again with --verbose.
Sep 21 13:29:58.216 INFO kablam! su: No module specific data is present
Sep 21 13:29:59.133 INFO running `"docker" "rm" "-f" "2134d970aaf5ae025f084243d3accd386f4cf25e7979d9316233e220d00a872e"`
Sep 21 13:29:59.253 INFO blam! 2134d970aaf5ae025f084243d3accd386f4cf25e7979d9316233e220d00a872e