Module opendal::io_util

Providing IO utils like into_sink, into_stream.

Structs

ReadObserver

Observer that created via observe_read.

SeekableReader

SeekableReader implement AsyncRead and AsyncSeek.

WriteObserver

Observer that created via observe_write.

Enums

CompressAlgorithm

CompressAlgorithm represents all compress algorithm that OpenDAL supports.

ReadEvent

Event that sent by ReadObserver, should be handled via FnMut(ReadEvent).

WriteEvent

Event that sent by WriteObserver, should be handled via FnMut(WriteEvent).

Functions

into_brotli_reader

Wrap input reader into brotli decoder.

into_bz2_reader

Wrap input reader into bz2 decoder.

into_deflate_reader

Wrap input reader into deflate decoder.

into_gzip_reader

Wrap input reader into gzip decoder.

into_lzma_reader

Wrap input reader into lzma decoder.

into_reader

Convert BytesStream into BytesRead.

into_sink

Convert BytesWrite into BytesSink.

into_stream

Convert BytesRead into BytesStream.

into_writer

Convert BytesSink into BytesWrite.

into_xz_reader

Wrap input reader into xz decoder.

into_zlib_reader

Wrap input reader into zlib decoder.

into_zstd_reader

Wrap input reader into zstd decoder.

observe_read

Create an observer over BytesReader.

observe_write

Create an observer over crate::BytesWrite.

seekable_read

Add seek support for object via internal lazy operation.