pub fn init_stream(conn_info: EventConnectionInfo, event_core: EventCore) {
    INIT.call_once(|| {
            let event_stream = init_nats_stream(conn_info).expect("Could not start NATS thread");
            EVENT_STREAM.set(event_stream);
            EVENT_CORE.set(event_core);
        });
}
/// Starts a new thread for sending events to a NATS Streaming
/// server. Stashes the handle to the stream, as well as the core
/// event information that will be a part of all events, in a global
/// static reference for access later.
Starts a new thread for sending events to a NATS Streaming
server. Stashes the handle to the stream, as well as the core
event information that will be a part of all events, in a global
static reference for access later.
Starts a new thread for sending events to a NATS Streaming server . Stashes the handle to the stream as well as the core event information that will be a part of all events in a global static reference for access later .
pub fn init_stream(conn_info: EventConnectionInfo, event_core: EventCore) {
    INIT.call_once(|| {
            let event_stream = init_nats_stream(conn_info).expect("Could not start NATS thread");
            EVENT_STREAM.set(event_stream);
            EVENT_CORE.set(event_core);
        });
}
pub fn init_stream ( conn_info : EventConnectionInfo , event_core : EventCore ) { INIT . call_once ( | | { let event_stream = init_nats_stream ( conn_info ) . expect ( " " ) ; EVENT_STREAM . set ( event_stream ) ; EVENT_CORE . set ( event_core ) ; } ) ; }
Starts a new thread for sending events to a NATS Streaming
server.
Starts a new thread for sending events to a NATS Streaming server .
conn_info
EventConnectionInfo
event_core
EventCore
conn_info
EventConnectionInfo
event_core
EventCore