Struct DataPipeSender 

pub struct DataPipeSender { /* private fields */ }

Sender for streaming data to the HTTP transport.

This is used with the callback-based import to send data chunks.

Implementations

impl DataPipeSender

pub async fn send(&self, data: Vec<u8>) -> Result<(), ImportError>

Send a chunk of data.

Arguments

• data - The data to send.

Errors

Returns ImportError::ChannelError if the channel is closed.

pub async fn send_row<I, T>( &self, row: I, separator: char, delimiter: char, row_separator: &RowSeparator, ) -> Result<(), ImportError>

where I: IntoIterator<Item = T>, T: AsRef<str>,

Send a CSV row as formatted data.

Arguments

• row - Iterator of field values.
• separator - Column separator character.
• delimiter - Column delimiter character.
• row_separator - Row separator to append.

Errors

Returns ImportError::ChannelError if the channel is closed.