Struct RowSender 

pub struct RowSender {
    pub sent: Arc<AtomicUsize>,
    /* private fields */
}

A handle used by the background producer task to send rows to the consumer and to detect cancellation.

Fields

sent: Arc<AtomicUsize>

Tracks the total number of rows sent, exposed in tests.

Implementations

impl RowSender

pub async fn send_row(&self, row: Row) -> bool

Send a row, blocking until there is capacity in the channel.

Returns false if the stream was cancelled or the receiver was dropped (either means the producer should stop).

pub fn is_cancelled(&self) -> bool

Returns true if the stream has been cancelled.

pub fn cancel_token(&self) -> CancellationToken

Return a clone of the cancellation token so that producers can select! against it while awaiting a slow I/O operation.

pub async fn send_error(&self, err: SdkError) -> bool

Send an error to the consumer.

Returns false if the stream was cancelled or the receiver was dropped.