Futures ZMQ

This crate contains wrappers around ZeroMQ Concepts with Futures.

See the examples folder for usage examples.

Getting Started

toml futures-zmq = "0.1" futures = "0.1.25"

In your application: ```rust use std::sync::Arc;

use futures::Future; use futures_zmq::Session;

fn main() { let ctx = Arc::new(zmq::Context::new()); let socket = ctx.socket(SocketType::REP) .unwrap();

socket.bind("tcp://*:5560")
    .unrwap();

let session = Session::new();

session.recv(socket)
    .and_then(move |(socket, message)| {
        /// Echo the message back to the client
        session.send(socket, message, 0)
    })
    .wait()
    .unwrap();

} ```

Running the examples

The req.rs and rep.rs examples are designed to be used together. The rep example starts a server with a REP socket, and the req example queries that server with a REQ socket.

Contributing

Feel free to open issues for anything you find an issue with. Please note that any contributed code will be licensed under the GPLv3.

License

Futures ZMQ is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

Futures ZMQ is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. This file is part of Futures ZMQ.

You should have received a copy of the GNU General Public License along with Futures ZMQ. If not, see http://www.gnu.org/licenses/.