liminal-server 0.24.9

Standalone server for the liminal messaging bus
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use super::Fixture;
use crate::server::runtime::runtime_links::{ConfiguredLinks, shutdown};

impl Drop for Fixture {
    fn drop(&mut self) {
        let stopped = shutdown(
            &self.supervisor,
            std::time::Duration::ZERO,
            || Ok(()),
            (&mut ConfiguredLinks::default(), || self.sink.drain()),
        );
        if let Err(error) = stopped {
            eprintln!("mount fixture shutdown failed: {error}");
            assert!(
                std::thread::panicking(),
                "mount fixture shutdown failed: {error}"
            );
        }
    }
}