Method send_event

crates/hyperqueue/src/server/event/streamer.rs:364–393

(
        &self,
        payload: EventPayload,
        now: Option<DateTime<Utc>>,
        forward_mode: ForwardMode,
    )

    }

    fn send_event(
        &self,
        payload: EventPayload,
        now: Option<DateTime<Utc>>,
        forward_mode: ForwardMode,
    ) {
        let mut inner = self.inner.get_mut();
        if inner.storage_sender.is_none() && inner.client_listeners.is_empty() {
            return;
        }
        let event = Event {
            time: now.unwrap_or_else(Utc::now),
            payload,
        };

        inner.client_listeners.retain(|listener| {
            if listener.filter.check(&event.payload) {
                listener.sender.send(event.clone()).is_ok()
            } else {
                true
            }
        });

        if let Some(ref streamer) = inner.storage_sender
            && matches!(forward_mode, ForwardMode::StreamAndPersist)
            && streamer.send(EventStreamMessage::Event(event)).is_err()
        {
            log::error!("Event streaming queue has been closed.");
        }
    }

    pub fn on_server_stop(&self) {
        self.send_event(