Skip to main content

execute

allsource_core::infrastructure::resp::commands

Function execute 

Source 
pub fn execute(
    args: &[RespValue],
    store: &Arc<EventStore>,
) -> (RespValue, Option<SubscriptionInfo>)
Expand description

Execute a parsed RESP command against the EventStore.

Returns (response, Option<subscription>) — subscription is Some only for SUBSCRIBE, giving the caller a broadcast receiver and filters.