pub(crate) fn new(
        channel: mpsc::UnboundedSender<Vec<Row>>,
        emit_progress: bool,
        object_columns: usize,
    ) -> Self {
        Self {
            channel,
            emit_progress,
            object_columns,
        }
    }
/// 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
/// * `object_columns` is the arity of the sink relation.
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
`object_columns` is the arity of the sink relation.
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 ` object_columns ` is the arity of the sink relation .
pub(crate) fn new(
        channel: mpsc::UnboundedSender<Vec<Row>>,
        emit_progress: bool,
        object_columns: usize,
    ) -> Self {
        Self {
            channel,
            emit_progress,
            object_columns,
        }
    }
pub ( crate ) fn new ( channel : mpsc :: UnboundedSender < Vec < Row > > , emit_progress : bool , object_columns : usize , ) -> Self { Self { channel , emit_progress , object_columns , } }
Create a new [PendingTail].
Create a new [ PendingTail ] .
channel
mpsc::UnboundedSender<Vec<Row>>
emit_progress
bool
object_columns
usize
channel
mpsc::UnboundedSender<Vec<Row>>
emit_progress
bool
object_columns
usize