Skip to main content

subscription_query_response

laminardb::pgwire

Function subscription_query_response 

Source 
fn subscription_query_response(
    portal: SubscriptionPortal,
    result_format: Option<&Format>,
) -> Response
Expand description

Wrap a SubscriptionPortal in a pgwire Response::Query so the framework can chunk via Execute(max_rows) and emit PortalSuspended automatically. Used by the chunked extended-query path.