/// Reports the current since frontier.
Reports the current since frontier.
Reports the current since frontier .
async fn since<K, V>(
        &mut self,
        collection: StashCollection<K, V>,
    ) -> Result<Antichain<Timestamp>, StashError>
    where
        K: Data,
        V: Data,
    {
        let tx = self.conn.transaction()?;
        let since = Self::since_tx(&tx, collection.id)?;
        tx.commit()?;
        Ok(since)
    }
async fn since < K , V > ( & mut self , collection : StashCollection < K , V > , ) -> Result < Antichain < Timestamp > , StashError > where K : Data , V : Data , { let tx = self . conn . transaction ( ) ? ; let since = Self :: since_tx ( & tx , collection . id ) ? ; tx . commit ( ) ? ; Ok ( since ) }
Reports the current since frontier.
Reports the current since frontier .
&mut self
collection
StashCollection<K, V>