Skip to main content

IpcMessageSink

Trait IpcMessageSink 

Source
trait IpcMessageSink {
    // Required method
    fn write_slice(&mut self, bytes: &[u8]) -> Result<(), ArrowError>;

    // Provided methods
    fn write_vec(&mut self, bytes: Vec<u8>) -> Result<(), ArrowError> { ... }
    fn write_encoded_buffer(
        &mut self,
        buffer: EncodedBuffer,
    ) -> Result<(), ArrowError> { ... }
}
Expand description

Destination-specific byte writing for a framed IPC message.

The default owned-buffer methods borrow their bytes and call write_slice, which can copy the data. Sink implementations that can take ownership of generated bytes should override write_vec or write_encoded_buffer.

Required Methods§

Source

fn write_slice(&mut self, bytes: &[u8]) -> Result<(), ArrowError>

Provided Methods§

Source

fn write_vec(&mut self, bytes: Vec<u8>) -> Result<(), ArrowError>

Source

fn write_encoded_buffer( &mut self, buffer: EncodedBuffer, ) -> Result<(), ArrowError>

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§

Source§

impl IpcMessageSink for Buffers<'_>

Source§

impl<W> IpcMessageSink for W
where W: Write,