Skip to main content

dispatch_subscribe

Function dispatch_subscribe 

Source
pub async fn dispatch_subscribe(
    state: &AppState,
    ctx: RequestContext,
) -> Result<(Vec<Frame>, ExecutionMetrics), ExecuteError>
Expand description

Dispatch a subscribe operation through the actor with interceptors.

Separate from dispatch() because Subscribe uses Reply<ServerSubscribeResponse> rather than Reply<ServerResponse>.