Struct coord::tail::PendingTail

pub(crate) struct PendingTail {
    channel: UnboundedSender<Vec<Row>>,
    emit_progress: bool,
    arity: usize,
}

A description of a pending tail from coord’s perspective

Fields

channel: UnboundedSender<Vec<Row>>

Channel to send responses to the client

The responses have the form Vec<Row> but should perhaps become TailResponse.

emit_progress: bool

Whether progress information should be emitted

arity: usize

Number of columns in the output

Implementations

impl PendingTail

pub(crate) fn new(
    channel: UnboundedSender<Vec<Row>>,
    emit_progress: bool,
    arity: usize
) -> Self

Create a new PendingTail.

• The channel receives batches of finalized rows.
• If emit_progress is true, the finalized rows are either data or progress updates
• arity is the arity of the sink relation.

pub(crate) fn process_response(&mut self, response: TailResponse) -> bool

Process a tail response

Returns true if the sink should be removed.