Struct AsyncCopyInWriterOwned 

pub struct AsyncCopyInWriterOwned { /* private fields */ }

Owned-handle variant of AsyncCopyInWriter that holds an Arc<Mutex<_>> to the underlying connection instead of a borrow. Used by callers that need a 'static-lifetime writer — e.g. N-API classes that can’t carry borrowed references across JS callbacks.

Semantics are identical to AsyncCopyInWriter; the only difference is lifetime.

Implementations

impl AsyncCopyInWriterOwned

pub async fn send(&mut self, data: &[u8]) -> Result<()>

Sends data to the server.

Errors

Currently infallible — frame construction is pure. The Result return type is preserved for forward compatibility.

pub async fn flush(&mut self) -> Result<()>

Flushes any buffered data to the server.

Errors

Returns Error (I/O) if flushing the async transport fails.

pub async fn send_direct(&mut self, data: &[u8]) -> Result<()>

Sends COPY data directly to the stream without internal buffering.

Errors

• Returns Error (protocol) if data.len() + 4 exceeds u32::MAX.
• Returns Error (I/O) on transport write failure.

pub async fn flush_stream(&mut self) -> Result<()>

Flushes the TCP stream.

Errors

Returns Error (I/O) if flushing the async transport fails.

pub async fn finish(self) -> Result<u64>

Finishes the COPY operation and returns the number of rows inserted.

Errors

Returns Error (server) if the server reports an ErrorResponse (e.g. constraint violation), or Error (I/O) / Error (closed) on transport failure.

pub async fn cancel(self, reason: &str) -> Result<()>

Cancels the COPY operation.

Errors

Returns Error (I/O) on transport write failure, or Error (closed) if the server drops the connection before acknowledging the cancel.

Trait Implementations

impl Debug for AsyncCopyInWriterOwned

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for AsyncCopyInWriterOwned

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.