Struct Compat 

pub struct Compat<T> { /* private fields */ }

Compatibility adapter for futures and I/O types.

Implementations

impl<T> Compat<T>

pub fn new(inner: T) -> Self

Create a new Compat wrapper around the given value.

Trait Implementations

impl<T: Clone> Clone for Compat<T>

fn clone(&self) -> Compat<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for Compat<T>

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

Formats the value using the given formatter.

impl<T> Drop for Compat<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<F: FileSystem> FileSystem for Compat<F>

Compatibility adapter for FileSystem implementations that are based on Tokio.

fn list(&self, prefix: &str) -> BoxStream<'_, VortexResult<FileListing>>

Recursively list files whose paths start with prefix.

fn open_read<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = VortexResult<Arc<dyn VortexReadAt>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Open a file for reading at the given path.

impl<T: Future> Future for Compat<T>

type Output = <T as Future>::Output

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<S: Stream> Stream for Compat<S>

type Item = <S as Stream>::Item

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<R: VortexReadAt> VortexReadAt for Compat<R>

Compatibility adapter for VortexReadAt implementations that are based on Tokio.

fn uri(&self) -> Option<&Arc<str>>

URI for debugging/logging. Returns None for anonymous sources.

fn coalesce_config(&self) -> Option<CoalesceConfig>

Configuration for merging nearby I/O requests into fewer, larger reads.

fn concurrency(&self) -> usize

Maximum number of concurrent I/O requests for that should be pulled from this source.

fn size(&self) -> BoxFuture<'static, VortexResult<u64>>

Asynchronously get the number of bytes of the underlying source.

fn read_at( &self, offset: u64, length: usize, alignment: Alignment, ) -> BoxFuture<'static, VortexResult<BufferHandle>>

Request an asynchronous positional read. Results will be returned as a BufferHandle.

impl<W: VortexWrite> VortexWrite for Compat<W>

Compatibility adapter for VortexWrite implementations that are based on Tokio.

fn write_all<B: IoBuf>(&mut self, buffer: B) -> impl Future<Output = Result<B>>

fn flush(&mut self) -> impl Future<Output = Result<()>>

fn shutdown(&mut self) -> impl Future<Output = Result<()>>

impl<'__pin, T> Unpin for Compat<T>

where PinnedFieldsOf<__Origin<'__pin, T>>: Unpin,