The answer to a statement queued with queue or queue_execute: its rows, or the count of rows
it changed. The statements queued so far get a sync point first if they have none, so the batch
ends. Pendings may be taken in any order; results read on the way are kept for their own take.
- p: the pipeline the statement was queued on.
- pending: what
queueorqueue_executereturned.
take :: (p: *Pipeline, pending: Pending($R)) -> (R, Pg_Error)The answer to a statement queued with queue or queue_execute: its rows, or the count of rows
it changed. The statements queued so far get a sync point first if they have none, so the batch
ends. Pendings may be taken in any order; results read on the way are kept for their own take.
Parameters
- p: *Pipeline
- the pipeline the statement was queued on.
- pending: Pending($R)
- what
queueorqueue_executereturned.
Returns
- R