photon-backend 0.1.0

Photon publish/subscribe backend implementations and storage adapters
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Registry of `#[photon::subscribe]` handlers discovered via inventory.

#![allow(missing_docs)]

use crate::handler_descriptor::HandlerDescriptor;

quark::define_registry! {
    /// Registry of inventory-submitted subscription handlers.
    pub struct HandlerRegistry for HandlerDescriptor;
}

impl HandlerRegistry {
    /// Handlers for a topic in stable registry-key order.
    #[must_use]
    pub fn for_topic(&self, topic_name: &str) -> Vec<&'static HandlerDescriptor> {
        let mut handlers: Vec<&'static HandlerDescriptor> = self
            .iter()
            .filter(|h| h.topic_name == topic_name)
            .collect();
        handlers.sort_by_key(|h| h.registry_key);
        handlers
    }
}