liminal-server 0.24.2

Standalone server for the liminal messaging bus
Documentation 
1
2
3
4
5
6
7
8
9
10
11

use super::{ConnectionControl, NativeOutcome, WebSocketConnectionProcess};

impl WebSocketConnectionProcess {
    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
        }
    }
}