Initial 0.1.0 release

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "tmq"
-version = "0.0.2"
+version = "0.1.0"
 authors = ["cetra3 <[email protected]>"]
 license = "MIT/Apache-2.0"
 description = "ZeroMQ bindings for Tokio"
@@ -12,7 +12,7 @@ futures = "0.1"
 mio = "0.6"
 tokio = "0.1"
 tokio-io = "0.1"
-tmq-zmq = { version = "0.9.0", path = "./rust-zmq" }
+zmq = "0.9.0"
 failure = "0.1"
 log = "0.4"
 

examples/publish.rs

@@ -47,5 +47,6 @@ fn make_broadcast() -> impl Stream<Item = Message, Error = Error> {
             let message = format!("Broadcast #{}", i);
             info!("Publish: {}", message);
             Message::from(&message)
-        }).from_err()
+        })
+        .from_err()
 }

examples/request.rs

@@ -30,7 +30,8 @@ fn main() {
         .for_each(|val| {
             info!("Response: {}", val.as_str().unwrap_or(""));
             Ok(())
-        }).map_err(|err| {
+        })
+        .map_err(|err| {
             error!("Error with request: {}", err);
         });
 

examples/response.rs

@@ -28,7 +28,8 @@ fn main() {
         .with(|msg: Message| {
             info!("Request: {}", msg.as_str().unwrap_or(""));
             Ok(msg)
-        }).map_err(|err| {
+        })
+        .map_err(|err| {
             error!("Error from server:{}", err);
         });
 

examples/subscribe.rs

@@ -28,7 +28,8 @@ fn main() {
         .for_each(|val| {
             info!("Subscribe: {}", val.as_str().unwrap_or(""));
             Ok(())
-        }).map_err(|e| {
+        })
+        .map_err(|e| {
             error!("Error Subscribing: {}", e);
         });