Skip to main content

handle_batch_subscribe

reifydb_sub_server::subscription::handler

Function handle_batch_subscribe 

Source 
pub async fn handle_batch_subscribe<S: WireSink>(
    state: &AppState,
    connection_id: ConnectionId,
    identity: IdentityId,
    queries: &[String],
    sink: S,
    registry: &Arc<SubscriptionRegistry<S>>,
    format: S::Format,
    shutdown: Receiver<bool>,
    metadata: RequestMetadata,
) -> Result<BatchAck, BatchSubscribeError>