pub fn new(node: inspect::Node) -> Self {
        let (internal_sender, internal_receiver) = mpsc::channel(MAX_EVENT_BUS_CAPACITY);
        let (external_sender, external_receiver) = mpsc::channel(MAX_EVENT_BUS_CAPACITY);
        Self {
            consumers: BTreeMap::new(),
            internal_sender,
            internal_receiver,
            external_sender,
            external_receiver,
            producers_registered: BTreeSet::new(),
            inspect_logger: EventStreamLogger::new(node),
        }
    }
/// Creates a new empty event router.
Creates a new empty event router.
Creates a new empty event router .
pub fn new(node: inspect::Node) -> Self {
        let (internal_sender, internal_receiver) = mpsc::channel(MAX_EVENT_BUS_CAPACITY);
        let (external_sender, external_receiver) = mpsc::channel(MAX_EVENT_BUS_CAPACITY);
        Self {
            consumers: BTreeMap::new(),
            internal_sender,
            internal_receiver,
            external_sender,
            external_receiver,
            producers_registered: BTreeSet::new(),
            inspect_logger: EventStreamLogger::new(node),
        }
    }
pub fn new ( node : inspect :: Node ) -> Self { let ( internal_sender , internal_receiver ) = mpsc :: channel ( MAX_EVENT_BUS_CAPACITY ) ; let ( external_sender , external_receiver ) = mpsc :: channel ( MAX_EVENT_BUS_CAPACITY ) ; Self { consumers : BTreeMap :: new ( ) , internal_sender , internal_receiver , external_sender , external_receiver , producers_registered : BTreeSet :: new ( ) , inspect_logger : EventStreamLogger :: new ( node ) , } }
Creates a new empty event router.
Creates a new empty event router .
node
inspect::Node
node
inspect::Node