Trait tc_table::TableStream

pub trait TableStream: TableInstance + Sized {
    type Limit: TableInstance;
    type Selection: TableInstance;
    fn limit(self, limit: u64) -> Self::Limit;
    fn select(self, columns: Vec<Id>) -> TCResult<Self::Selection>;
    fn rows<'a, 'async_trait>(
        self, 
        txn_id: TxnId
    ) -> Pin<Box<dyn Future<Output = TCResult<TCBoxTryStream<'a, Vec<Value>>>> + Send + 'async_trait>>
    where
        'a: 'async_trait,
        Self: 'async_trait;

    fn count<'async_trait>(
        self, 
        txn_id: TxnId
    ) -> Pin<Box<dyn Future<Output = TCResult<u64>> + Send + 'async_trait>>
    where
        Self: Send + 'async_trait,
    { ... }
}

Table read methods

Associated Types

type Limit: TableInstance

type Selection: TableInstance

Required methods

fn limit(self, limit: u64) -> Self::Limit

Limit the number of rows returned by rows.

fn select(self, columns: Vec<Id>) -> TCResult<Self::Selection>

Limit the columns returned by rows.

fn rows<'a, 'async_trait>(
    self,
    txn_id: TxnId
) -> Pin<Box<dyn Future<Output = TCResult<TCBoxTryStream<'a, Vec<Value>>>> + Send + 'async_trait>> where
    'a: 'async_trait,
    Self: 'async_trait, 

Return a stream of the rows in this Table.

Provided methods

fn count<'async_trait>(
    self,
    txn_id: TxnId
) -> Pin<Box<dyn Future<Output = TCResult<u64>> + Send + 'async_trait>> where
    Self: Send + 'async_trait, 

Return the number of rows in this Table.

Implementors

impl<F: File<Node>, D: Dir, Txn: Transaction<D>> TableStream for Table<F, D, Txn> where
    Self: Send + Sync, 

type Limit = Self

type Selection = Self

impl<F: File<Node>, D: Dir, Txn: Transaction<D>> TableStream for Merged<F, D, Txn>

type Limit = Limited<F, D, Txn>

type Selection = Selection<F, D, Txn, Self>

impl<F: File<Node>, D: Dir, Txn: Transaction<D>> TableStream for TableIndex<F, D, Txn>

type Limit = Limited<F, D, Txn>

type Selection = Selection<F, D, Txn, Self>