Local publish/subscribe

Documentation

http://fuchsnj.github.io/rust_pubsub

Usage

This will be uploaded to crates.io when it is more stable. For now, add the following to your Cargo.toml

toml [dependencies.pubsub] git = "https://github.com/fuchsnj/rust_pubsub.git"

and this to your crate root:

rust extern crate pubsub;

Quick Start

```rust //create pubsub with 5 threads. These threads run notification functions. //messages are queued indefinitely until they can be run let pubsub = PubSub::new(5);

//subscribe to a channel. The subscription will stay active as long
//as sub1 stays in scope
let sub1 = pubsub.subscribe("channel1", move |msg|{
    println!("channel 1 was notified with msg: {}", msg);
});

//notify all subscribers of "channel1" with message "data1"
//This will always return immediately since messages are queued
pubsub.notify("channel1", "data1", None);

//notify all subscribers of "channel1" except sub1
pubsub.notify("channel1", "data2", Some(sub1));

//notify all subscribers of "channel1" except sub1
sub1.notify_others("data3");

//If you want to start queueing messsages for a subscription, but
//don't want to process them until after some initialization
let sub2_activator = pubsub.lazy_subscribe("channel2");

//do some initialization here...

//notifications received here are queued
pubsub.notify("channel2", "data4", None);

//this creates a subscription and processes any messages in the backlog
let sub2 = sub2_activator.activate(move |msg|{
    println!("channel 2 was notified with msg: {}", msg);
});

//subscriptions can be cancelled by dropping or cancelling
drop(sub1);
sub2.cancel();

```