Fixed tests, I think :)

Author: olofwalker

examples/serde.rs

@@ -46,7 +46,10 @@ async fn main() {
                 println!("Received: {:?}", packet);
             }
 
-            let acks: Vec<String> = packets.into_iter().map(|packet| packet.0).collect();
+            let acks: Vec<String> = packets
+                .into_iter()
+                .map(|packet| packet.1)
+                .collect::<Vec<_>>();
             if !acks.is_empty() {
                 task::spawn(async move { order_sub.acknowledge_messages(acks).await })
                     .await // This will block until acknowledgement is complete

examples/subscribe_to_topic.rs

@@ -44,7 +44,10 @@ async fn main() {
     }
 
     if !packets.is_empty() {
-        let acks = packets.into_iter().map(|packet| packet.0).collect();
+        let acks = packets
+            .into_iter()
+            .map(|packet| packet.1)
+            .collect::<Vec<_>>();
         sub.acknowledge_messages(acks).await;
     } else {
         println!("Cleaning up");

src/subscription.rs

@@ -6,7 +6,6 @@ use hyper::{Method, StatusCode};
 use lazy_static::lazy_static;
 use log::error;
 use serde_derive::{Deserialize, Serialize};
-use std::collections::HashMap;
 use std::env;
 
 lazy_static! {