Enum reactive_messaging::prelude::SocketServer

pub enum SocketServer<const CONFIG: u64, RemoteMessages: ReactiveMessagingDeserializer<RemoteMessages> + Send + Sync + PartialEq + Debug + 'static, LocalMessages: ReactiveMessagingSerializer<LocalMessages> + Send + Sync + PartialEq + Debug + Default + 'static, const PROCESSOR_BUFFER: usize, const PROCESSOR_UNI_INSTRUMENTS: usize, const SENDER_BUFFER: usize> {
    Atomic(GenericSocketServer<CONFIG, RemoteMessages, LocalMessages, UniZeroCopyAtomic<RemoteMessages, PROCESSOR_BUFFER, 1, PROCESSOR_UNI_INSTRUMENTS>, ChannelUniMoveAtomic<LocalMessages, SENDER_BUFFER, 1>>),
    FullSync(GenericSocketServer<CONFIG, RemoteMessages, LocalMessages, UniZeroCopyFullSync<RemoteMessages, PROCESSOR_BUFFER, 1, PROCESSOR_UNI_INSTRUMENTS>, ChannelUniMoveFullSync<LocalMessages, SENDER_BUFFER, 1>>),
    Crossbeam(GenericSocketServer<CONFIG, RemoteMessages, LocalMessages, UniMoveCrossbeam<RemoteMessages, PROCESSOR_BUFFER, 1, PROCESSOR_UNI_INSTRUMENTS>, ChannelUniMoveCrossbeam<LocalMessages, SENDER_BUFFER, 1>>),
}

Represents a server built out of CONFIG (a u64 version of [ConstConfig], from which the other const generic parameters derive).
Don’t instantiate this struct directly – use new_socket_server!() instead.

Variants

Atomic(GenericSocketServer<CONFIG, RemoteMessages, LocalMessages, UniZeroCopyAtomic<RemoteMessages, PROCESSOR_BUFFER, 1, PROCESSOR_UNI_INSTRUMENTS>, ChannelUniMoveAtomic<LocalMessages, SENDER_BUFFER, 1>>)

FullSync(GenericSocketServer<CONFIG, RemoteMessages, LocalMessages, UniZeroCopyFullSync<RemoteMessages, PROCESSOR_BUFFER, 1, PROCESSOR_UNI_INSTRUMENTS>, ChannelUniMoveFullSync<LocalMessages, SENDER_BUFFER, 1>>)

Crossbeam(GenericSocketServer<CONFIG, RemoteMessages, LocalMessages, UniMoveCrossbeam<RemoteMessages, PROCESSOR_BUFFER, 1, PROCESSOR_UNI_INSTRUMENTS>, ChannelUniMoveCrossbeam<LocalMessages, SENDER_BUFFER, 1>>)

Implementations

impl<const CONFIG: u64, RemoteMessages: ReactiveMessagingDeserializer<RemoteMessages> + Send + Sync + PartialEq + Debug + 'static, LocalMessages: ReactiveMessagingSerializer<LocalMessages> + Send + Sync + PartialEq + Debug + Default + 'static, const PROCESSOR_BUFFER: usize, const PROCESSOR_UNI_INSTRUMENTS: usize, const SENDER_BUFFER: usize> SocketServer<CONFIG, RemoteMessages, LocalMessages, PROCESSOR_BUFFER, PROCESSOR_UNI_INSTRUMENTS, SENDER_BUFFER>

pub fn shutdown_waiter( &mut self ) -> Box<dyn FnOnce() -> BoxFuture<'static, Result<(), Box<dyn Error + Send + Sync>>>>

See GenericSocketServer::shutdown_waiter()

pub fn shutdown( self, timeout_ms: u32 ) -> Result<(), Box<dyn Error + Send + Sync>>

See GenericSocketServer::shutdown()