Struct Photon 

pub struct Photon<T: Copy + Send + 'static> { /* private fields */ }

Named-topic pub/sub bus.

Wraps channel with string-keyed topic routing. Each topic is an independent SPMC ring.

let bus = photon_ring::Photon::<u64>::new(64);
let mut pub_ = bus.publisher("prices");
let mut sub  = bus.subscribe("prices");
pub_.publish(100);
assert_eq!(sub.try_recv(), Ok(100));

Implementations

impl<T: Copy + Send + 'static> Photon<T>

pub fn new(capacity: usize) -> Self

Create a bus. capacity is the ring size for each topic (power of two).

pub fn publisher(&self, topic: &str) -> Publisher<T>

Take the publisher for a topic. Creates the topic if it doesn’t exist.

Panics

Panics if the publisher for this topic was already taken.

pub fn subscribe(&self, topic: &str) -> Subscriber<T>

Subscribe to a topic (future messages only). Creates the topic if needed.

pub fn subscribable(&self, topic: &str) -> Subscribable<T>

Get the clone-able subscriber factory for a topic.