Skip to main content

pamoja_event_bus_new

pamoja_ffi::bus

Function pamoja_event_bus_new 

Source 
#[unsafe(no_mangle)]
pub extern "C" fn pamoja_event_bus_new(
    capacity: usize,
) -> *mut PamojaEventBus
Expand description

Creates an event bus.

§Arguments

  • capacity - how many events a slow subscriber may fall behind before it starts missing them.

§Returns

A handle the caller must release with pamoja_event_bus_free.