liminal-server 0.24.1

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

use super::{ConnectionControl, ConnectionTransport, NativeOutcome, TransportConnectionProcess};

impl<T: ConnectionTransport> TransportConnectionProcess<T> {
    pub(super) fn force_close_if_pending(&mut self, pid: u64) -> Option<NativeOutcome> {
        if self.runtime.take_force_close(pid) {
            self.handle_control(pid, ConnectionControl::ForceClose)
        } else {
            None
        }
    }

    #[cfg(test)]
    pub(in crate::server::connection) fn track_conversation_for_tests(
        &mut self,
        conversation: u64,
    ) {
        self.state.participant_conversations.track(conversation);
    }
}