Struct coord::tail::PendingTail [−][src]
pub(crate) struct PendingTail {
channel: UnboundedSender<Vec<Row>>,
emit_progress: bool,
arity: usize,
}
Expand description
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
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.
Process a tail response
Returns true
if the sink should be removed.
Auto Trait Implementations
impl !RefUnwindSafe for PendingTail
impl Send for PendingTail
impl Sync for PendingTail
impl Unpin for PendingTail
impl !UnwindSafe for PendingTail
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more