47 lines
1.1 KiB
Rust
47 lines
1.1 KiB
Rust
use std::{pin::Pin, sync::Arc};
|
|
|
|
use conduit::Result;
|
|
use futures::{
|
|
stream::FusedStream,
|
|
task::{Context, Poll},
|
|
Stream,
|
|
};
|
|
use rocksdb::{ColumnFamily, ReadOptions};
|
|
|
|
use super::{slice_longevity, Cursor, From, State};
|
|
use crate::{keyval::Key, Engine};
|
|
|
|
pub(crate) struct Keys<'a> {
|
|
state: State<'a>,
|
|
}
|
|
|
|
impl<'a> Keys<'a> {
|
|
pub(crate) fn new(db: &'a Arc<Engine>, cf: &'a Arc<ColumnFamily>, opts: ReadOptions, from: From<'_>) -> Self {
|
|
Self {
|
|
state: State::new(db, cf, opts).init_fwd(from),
|
|
}
|
|
}
|
|
}
|
|
|
|
impl<'a> Cursor<'a, Key<'a>> for Keys<'a> {
|
|
fn state(&self) -> &State<'a> { &self.state }
|
|
|
|
#[inline]
|
|
fn fetch(&self) -> Option<Key<'a>> { self.state.fetch_key().map(slice_longevity) }
|
|
|
|
#[inline]
|
|
fn seek(&mut self) { self.state.seek_fwd(); }
|
|
}
|
|
|
|
impl<'a> Stream for Keys<'a> {
|
|
type Item = Result<Key<'a>>;
|
|
|
|
fn poll_next(mut self: Pin<&mut Self>, _ctx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
|
|
Poll::Ready(self.seek_and_get())
|
|
}
|
|
}
|
|
|
|
impl FusedStream for Keys<'_> {
|
|
#[inline]
|
|
fn is_terminated(&self) -> bool { !self.state.init && !self.state.valid() }
|
|
}
|