Enum AsyncWriteable 

pub enum AsyncWriteable {
    Dyn(AsyncDynWriteable),
    Local(File),
    Cloud(BufWriter),
}

Available on crate feature polars-io only.

Holds an async writeable file, abstracted over local files or cloud files.

This implements DerefMut to a trait object implementing [tokio::io::AsyncWrite].

Note: It is important that you do not call shutdown() on the deref’ed AsyncWrite object. You should instead call the AsyncWriteable::close at the end.

Variants

Dyn(AsyncDynWriteable)

Local(File)

Cloud(BufWriter)

Implementations

impl AsyncWriteable

pub async fn try_new( addr: PlPathRef<'_>, cloud_options: Option<&CloudOptions>, ) -> Result<AsyncWriteable, PolarsError>

pub async fn sync_on_close( &mut self, sync_on_close: SyncOnCloseType, ) -> Result<(), Error>

pub async fn close(self) -> Result<(), PolarsError>

Trait Implementations

impl Deref for AsyncWriteable

type Target = dyn AsyncWrite + Send + Unpin

The resulting type after dereferencing.

fn deref(&self) -> &<AsyncWriteable as Deref>::Target

Dereferences the value.

impl DerefMut for AsyncWriteable

fn deref_mut(&mut self) -> &mut <AsyncWriteable as Deref>::Target

Mutably dereferences the value.