Skip to content

ResultReceiver

[Source]

Receives the result of a Session.execute() call. The session is passed to each callback so receivers can execute follow-up queries without needing to store a session reference.

interface tag ResultReceiver

Public Behaviours

pg_query_result

[Source]

Called when a query completes successfully.

be pg_query_result(
  session: Session tag,
  result: Result)

Parameters

pg_query_failed

[Source]

Called when a query fails. The failure is either a server error (ErrorResponseMessage) or a client-side error (ClientQueryError) such as the session being closed (by the user, by peer TCP close, or by any other shutdown cause), never opened, or torn down after a server protocol violation (ProtocolViolation).

be pg_query_failed(
  session: Session tag,
  query: Query,
  failure: (ErrorResponseMessage val | ClientQueryError))

Parameters