Expand description
Providing IO utils like into_sink
, into_stream
.
Structs
BottomUpWalker will walk dir in bottom up way:
DecompressDecoder provides blocking decompress support for opendal: decode
happen
inside a blocking thread (user need to handle the decompress logic)
DecompressReader provides async decompress support for opendal: decode
happen inside poll_read
(will block the runtime)
Observer that created via observe_read
.
SeekableReader implement AsyncRead
and AsyncSeek
.
TopDownWalker will walk dir in top down way:
Observer that created via observe_write
.
Enums
CompressAlgorithm represents all compress algorithm that OpenDAL supports.
DecompressDecoder contains all decoders that opendal supports.
DecompressState is that decode state during decompress.
Event that sent by ReadObserver
, should be handled via
FnMut(ReadEvent)
.
Event that sent by WriteObserver
, should be handled via FnMut(WriteEvent)
.
Functions
Convert BytesStream
into BytesRead
.
Convert BytesWrite
into BytesSink
.
Convert BytesRead
into BytesStream
.
Convert BytesSink
into BytesWrite
.
Create an observer over BytesReader.
Create an observer over crate::BytesWrite
.
Add seek support for object via internal lazy operation.